Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for NewFrameReader (0.32 sec)

  1. pkg/api/testing/serialization_test.go

    		}
    		out := &bytes.Buffer{}
    		w := framer.NewFrameWriter(out)
    		if n, err := w.Write(obj.Bytes()); err != nil || n != len(obj.Bytes()) {
    			t.Fatal(err)
    		}
    		sr := streaming.NewDecoder(framer.NewFrameReader(io.NopCloser(out)), s)
    		resultSecret := &v1.Secret{}
    		res, _, err := sr.Decode(nil, resultSecret)
    		if err != nil {
    			t.Fatalf("%v:\n%s", err, hex.Dump(obj.Bytes()))
    		}
    		resultSecret.Kind = "Secret"
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Sep 25 11:04:08 UTC 2023
    - 19.3K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/endpoints/watch_test.go

    				}
    				objectCodec := codecs.DecoderToVersion(info.Serializer, testInternalGroupVersion)
    
    				var fr io.ReadCloser = r
    				if !protocol.selfFraming {
    					fr = streamSerializer.Framer.NewFrameReader(r)
    				}
    				d := streaming.NewDecoder(fr, streamSerializer.Serializer)
    
    				var w *watch.FakeWatcher
    				for w == nil {
    					w = simpleStorage.Watcher()
    					time.Sleep(time.Millisecond)
    				}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Nov 30 17:27:39 UTC 2023
    - 30K bytes
    - Viewed (0)
Back to top