Lines Matching refs:stream
636 /// A stream which limits the number of bytes it reads at a time.
701 // Create an output stream with a group in:
709 var stream = new MemoryStream();
710 var output = new CodedOutputStream(stream);
733 stream.Position = 0;
736 var input = new CodedInputStream(stream);
748 // Create an output stream with:
753 var stream = new MemoryStream();
754 var output = new CodedOutputStream(stream);
764 stream.Position = 0;
767 var input = new CodedInputStream(stream);
780 var stream = new MemoryStream();
781 var output = new CodedOutputStream(stream);
784 stream.Position = 0;
786 var input = new CodedInputStream(stream);
794 var stream = new MemoryStream();
795 var output = new CodedOutputStream(stream);
801 stream.Position = 0;
804 var input = new CodedInputStream(stream);
812 var stream = new MemoryStream();
813 var output = new CodedOutputStream(stream);
823 stream.Position = 0;
826 var input = new CodedInputStream(stream);
844 var stream = new MemoryStream();
845 Assert.Throws<ArgumentOutOfRangeException>(() => CodedInputStream.CreateWithLimits(stream, 0, 1));
846 Assert.Throws<ArgumentOutOfRangeException>(() => CodedInputStream.CreateWithLimits(stream, 1, 0));
868 Assert.IsTrue(memoryStream.CanRead); // We left the stream open
874 var stream = new CodedInputStream(new byte[10]);
875 stream.Dispose();
884 // Now make a MemoryStream that will fake a near-2GB stream of messages by returning
886 using (RepeatingMemoryStream stream = new RepeatingMemoryStream(serializedMessage, count))
888 Assert.DoesNotThrow(()=>TestAllTypes.Parser.ParseFrom(stream));
900 // Now make a MemoryStream that will fake a near-2GB stream of messages by returning
902 using (RepeatingMemoryStream stream = new RepeatingMemoryStream(serializedMessage, count))
904 Assert.Throws<InvalidProtocolBufferException>(() => TestAllTypes.Parser.ParseFrom(stream),