Found 186222 results in 23175 files, showing top 50 files (show more).
android.googlesource.com/platform/frameworks/ex:framesequence/jni/Stream.h: [ master, ] c++
24: class Stream {
44: class MemoryStream : public Stream {
46:     MemoryStream(void* buffer, size_t size, jobject buf) :
63: class FileStream : public Stream {
65:     FileStream(FILE* fd) : mFd(fd) {}
74: class JavaInputStream : public Stream {
76:     JavaInputStream(JNIEnv* env, jobject inputStream, jbyteArray byteArray) :
87:     const jobject mInputStream;
26:     Stream();
27:     virtual ~Stream();
78:             mInputStream(inputStream),
92: jint JavaStream_OnLoad(JNIEnv* env);
github.com/google/gulava:java/gulava/Stream.java: [ master, ] java
31: public interface Stream {
35:    * which the solutions are returned depends on the implementations of {@code Stream} used.
37:   Stream mplus(Stream s2);
44:   Stream bind(Goal goal);
55:   Stream rest();
github.com/apache/accumulo-testing:core/src/main/java/org/apache/accumulo/testing/core/stress/Stream.java: [ master, ] java
25: public abstract class Stream<T> implements Iterator<T> {
android.googlesource.com/platform/external/arduino:hardware/arduino/cores/arduino/Stream.h: [ master, ] c++
26: class Stream : public Print
21: #define Stream_h
2:   Stream.h - base class for character-based streams.
20: #ifndef Stream_h
github.com/llvm-mirror/llvm:tools/llvm-pdbutil/llvm-pdbutil.cpp: [ master, ] c++
664:     Stream("stream", cl::Required,
570: cl::opt<bool> StreamMetadata(
574: cl::opt<bool> StreamDirectory(
578: cl::opt<bool> PdbStream("pdb-stream",
585: cl::opt<bool> DbiStream("dbi-stream",
589: cl::opt<bool> TpiStream("tpi-stream",
593: cl::opt<bool> IpiStream("ipi-stream",
1229: static void exportStream() {
338:     DumpStreamData("stream-data", cl::CommaSeparated, cl::ZeroOrMore,
405: cl::opt<bool> DumpStreams("streams",
408: cl::opt<bool> DumpStreamBlocks(
520: cl::opt<bool> DumpNamedStreams("named-streams",
319: cl::OptionCategory DbiBytes("Dbi Stream Options");
320: cl::OptionCategory PdbBytes("PDB Stream Options");
579:                         cl::desc("Dump the PDB Stream (Stream 1)"),
586:                         cl::desc("Dump the DBI Stream Headers (Stream 2)"),
590:                         cl::desc("Dump the TPI Stream (Stream 3)"),
594:                         cl::desc("Dump the IPI Stream (Stream 5)"),
891:     llvm::raw_string_ostream Stream(CompressionStr);
892:     Stream << IS->getCompression();
911:     WithColor(Printer, PDB_ColorItem::LiteralValue).get() << Stream.str();
937:   auto &Stream = outs();
939:                             ? Stream.has_colors()
941:   LinePrinter Printer(2, UseColor, Stream);
1241:     if (to_integer(opts::exportstream::Stream, Index)) {
1254:     Index = ExitOnErr(IS.getNamedStreamIndex(opts::exportstream::Stream));
1255:     outs() << "Dumping contents of stream '" << opts::exportstream::Stream
56: #include "llvm/DebugInfo/PDB/Native/InfoStream.h"
64: #include "llvm/DebugInfo/PDB/Native/TpiStream.h"
76: #include "llvm/Support/BinaryByteStream.h"
646:                clEnumValN(InputFileType::PDBStream, "pdb-stream",
648:                clEnumValN(InputFileType::DBIStream, "dbi-stream",
652:                clEnumValN(InputFileType::ModuleStream, "mod-stream",
706:     ExitOnErr(Builder.getMsfBuilder().addStream(0));
716:   pdb::yaml::PdbInfoStream DefaultInfoStream;
717:   pdb::yaml::PdbDbiStream DefaultDbiStream;
718:   pdb::yaml::PdbTpiStream DefaultTpiStream;
719:   pdb::yaml::PdbTpiStream DefaultIpiStream;
721:   const auto &Info = YamlObj.PdbStream.getValueOr(DefaultInfoStream);
731:   const auto &Dbi = YamlObj.DbiStream.getValueOr(DefaultDbiStream);
747:       const auto &ModiStream = *MI.Modi;
748:       for (auto Symbol : ModiStream.Symbols) {
766:   const auto &Tpi = YamlObj.TpiStream.getValueOr(DefaultTpiStream);
774:   const auto &Ipi = YamlObj.IpiStream.getValueOr(DefaultIpiStream);
1179:     if (File.hasPDBTpiStream()) {
1180:       auto &Tpi = ExitOnErr(File.getPDBTpiStream());
1184:     if (File.hasPDBIpiStream()) {
1185:       auto &Ipi = ExitOnErr(File.getPDBIpiStream());
1197:     ExitOnErr(Builder.getMsfBuilder().addStream(0));
1233:   std::unique_ptr<MappedBlockStream> SourceStream;
1253:     InfoStream &IS = cantFail(File.getPDBInfoStream());
1259:   SourceStream = MappedBlockStream::createIndexedStream(
1262:       FileOutputBuffer::create(OutFileName, SourceStream->getLength()));
1263:   FileBufferByteStream DestStream(std::move(OutFile), llvm::support::little);
1264:   BinaryStreamWriter Writer(DestStream);
1265:   ExitOnErr(Writer.writeStreamRef(*SourceStream));
1266:   ExitOnErr(DestStream.commit());
1352:       opts::pdb2yaml::StreamMetadata = true;
1353:       opts::pdb2yaml::StreamDirectory = true;
1354:       opts::pdb2yaml::PdbStream = true;
1356:       opts::pdb2yaml::DbiStream = true;
1357:       opts::pdb2yaml::TpiStream = true;
1358:       opts::pdb2yaml::IpiStream = true;
1371:       opts::pdb2yaml::DbiStream = true;
1436:     exportStream();
47: #include "llvm/DebugInfo/CodeView/TypeStreamMerger.h"
55: #include "llvm/DebugInfo/PDB/Native/DbiStreamBuilder.h"
57: #include "llvm/DebugInfo/PDB/Native/InfoStreamBuilder.h"
65: #include "llvm/DebugInfo/PDB/Native/TpiStreamBuilder.h"
705:   for (uint32_t I = 0; I < kSpecialStreamCount; ++I)
1196:   for (uint32_t I = 0; I < kSpecialStreamCount; ++I)
1242:       if (Index >= File.getNumStreams()) {
1336:       opts::dump::DumpStreams = true;
1337:       opts::dump::DumpStreamBlocks = true;
github.com/google/highwayhash:highwayhash/vector256.h: [ master, ] c++
671: HH_INLINE void Stream(const V256<T>& v, T* const HH_RESTRICT to) {
674: HH_INLINE void Stream(const V256<float>& v, float* const HH_RESTRICT to) {
677: HH_INLINE void Stream(const V256<double>& v, double* const HH_RESTRICT to) {
github.com/apache/cordova-android:node_modules/sax/lib/sax.js: [ master, ] javascript
141:   var Stream = require("stream").Stream
143:   var Stream = function () {}
221:   return Stream.prototype.on.call(me, ev, handler)
151: function createStream (strict, opt) {
158:   Stream.apply(me)
195: SAXStream.prototype = Object.create(Stream.prototype,
6: sax.SAXStream = SAXStream
7: sax.createStream = createStream
152:   return new SAXStream(strict, opt)
155: function SAXStream (strict, opt) {
156:   if (!(this instanceof SAXStream)) return new SAXStream(strict, opt)
196:   { constructor: { value: SAXStream } })
198: SAXStream.prototype.write = function (data) {
204: SAXStream.prototype.end = function (chunk) {
210: SAXStream.prototype.on = function (ev, handler) {
android.googlesource.com/platform/frameworks/compile/libbcc:bcinfo/BitReader_2_7/BitcodeReader.cpp: [ master, ] c++
191:   BitstreamCursor Stream;
190:   std::unique_ptr<BitstreamReader> StreamFile;
3416: std::error_code BitcodeReader::InitStream() {
3441: std::error_code BitcodeReader::InitLazyStream() {
192:   std::unique_ptr<DataStreamer> LazyStreamer;
3422: std::error_code BitcodeReader::InitStreamFromBuffer() {
838:   if (Stream.EnterSubBlock(bitc::PARAMATTR_BLOCK_ID))
850:     BitstreamEntry Entry = Stream.advanceSkippingSubblocks();
865:     switch (Stream.readRecord(Entry.ID, Record)) {
896:   if (Stream.EnterSubBlock(bitc::TYPE_BLOCK_ID_NEW))
913:     BitstreamEntry Entry = Stream.advanceSkippingSubblocks();
931:     switch (Stream.readRecord(Entry.ID, Record)) {
1105:   if (Stream.EnterSubBlock(TYPE_BLOCK_ID_OLD_3_0))
1115:   BitstreamCursor StartOfTypeBlockCursor(Stream);
1126:     unsigned Code = Stream.ReadCode();
1138:         Stream = StartOfTypeBlockCursor;
1142:       if (Stream.ReadBlockEnd())
1149:       Stream.ReadSubBlockID();
1150:       if (Stream.SkipBlock())
1156:       Stream.ReadAbbrevRecord();
1163:     switch (Stream.readRecord(Code, Record)) {
1294:   if (Stream.EnterSubBlock(TYPE_SYMTAB_BLOCK_ID_OLD_3_0))
1302:     unsigned Code = Stream.ReadCode();
1304:       if (Stream.ReadBlockEnd())
1311:       Stream.ReadSubBlockID();
1312:       if (Stream.SkipBlock())
1318:       Stream.ReadAbbrevRecord();
1324:     switch (Stream.readRecord(Code, Record)) {
1345:   if (Stream.EnterSubBlock(bitc::VALUE_SYMTAB_BLOCK_ID))
1353:     unsigned Code = Stream.ReadCode();
1355:       if (Stream.ReadBlockEnd())
1361:       Stream.ReadSubBlockID();
1362:       if (Stream.SkipBlock())
1368:       Stream.ReadAbbrevRecord();
1374:     switch (Stream.readRecord(Code, Record)) {
1407:   if (Stream.EnterSubBlock(bitc::METADATA_BLOCK_ID))
1414:     unsigned Code = Stream.ReadCode();
1416:       if (Stream.ReadBlockEnd())
1423:       Stream.ReadSubBlockID();
1424:       if (Stream.SkipBlock())
1430:       Stream.ReadAbbrevRecord();
1437:     Code = Stream.readRecord(Code, Record);
1449:       Code = Stream.ReadCode();
1452:       unsigned NextBitCode = Stream.readRecord(Code, Record);
1626:   if (Stream.EnterSubBlock(bitc::CONSTANTS_BLOCK_ID))
1635:     BitstreamEntry Entry = Stream.advanceSkippingSubblocks();
1657:     unsigned BitCode = Stream.readRecord(Entry.ID, Record);
1961:   if (Stream.ReadBlockEnd())
1988:   uint64_t CurBit = Stream.GetCurrentBitNo();
1992:   if (Stream.SkipBlock())
2028:     Stream.JumpToBit(NextUnreadBit);
2029:   else if (Stream.EnterSubBlock(bitc::MODULE_BLOCK_ID))
2037:   while (!Stream.AtEndOfStream()) {
2038:     unsigned Code = Stream.ReadCode();
2040:       if (Stream.ReadBlockEnd())
2073:       switch (Stream.ReadSubBlockID()) {
2075:         if (Stream.SkipBlock())
2079:         if (Stream.ReadBlockInfoBlock())
2132:           NextUnreadBit = Stream.GetCurrentBitNo();
2142:       Stream.ReadAbbrevRecord();
2147:     switch (Stream.readRecord(Code, Record)) {
2347:   if (Stream.Read(8) != 'B' ||
2348:       Stream.Read(8) != 'C' ||
2349:       Stream.Read(4) != 0x0 ||
2350:       Stream.Read(4) != 0xC ||
2351:       Stream.Read(4) != 0xE ||
2352:       Stream.Read(4) != 0xD)
2358:     if (Stream.AtEndOfStream())
2362:       Stream.advance(BitstreamCursor::AF_DontAutoprocessAbbrevs);
2373:         if (Stream.ReadBlockInfoBlock())
2387:         if (Stream.SkipBlock())
2398:       if (Stream.getAbbrevIDWidth() == 2 && Entry.ID == 2 &&
2399:           Stream.Read(6) == 2 && Stream.Read(24) == 0xa0a0a &&
2400:           Stream.AtEndOfStream())
2409:   if (Stream.EnterSubBlock(bitc::MODULE_BLOCK_ID))
2417:     BitstreamEntry Entry = Stream.advanceSkippingSubblocks();
2431:     switch (Stream.readRecord(Entry.ID, Record)) {
2459:   if (Stream.Read(8) != 'B' ||
2460:       Stream.Read(8) != 'C' ||
2461:       Stream.Read(4) != 0x0 ||
2462:       Stream.Read(4) != 0xC ||
2463:       Stream.Read(4) != 0xE ||
2464:       Stream.Read(4) != 0xD)
2470:     BitstreamEntry Entry = Stream.advance();
2483:       if (Stream.SkipBlock())
2488:       Stream.skipRecord(Entry.ID);
2496:   if (Stream.EnterSubBlock(bitc::METADATA_ATTACHMENT_ID))
2501:     BitstreamEntry Entry = Stream.advanceSkippingSubblocks();
2516:     switch (Stream.readRecord(Entry.ID, Record)) {
2543:   if (Stream.EnterSubBlock(bitc::FUNCTION_BLOCK_ID))
2563:     unsigned Code = Stream.ReadCode();
2565:       if (Stream.ReadBlockEnd())
2571:       switch (Stream.ReadSubBlockID()) {
2573:         if (Stream.SkipBlock())
2598:       Stream.ReadAbbrevRecord();
2605:     unsigned BitCode = Stream.readRecord(Code, Record);
3332:   Stream.JumpToBit(DFII->second);
3436:   Stream.init(&*StreamFile);
3448:   Stream.init(&*StreamFile);
354:   std::error_code InitStream();
356:   std::error_code InitLazyStream();
2343:   if (std::error_code EC = InitStream())
2455:   if (std::error_code EC = InitStream())
3418:     return InitLazyStream();
3435:   StreamFile.reset(new BitstreamReader(BufPtr, BufEnd));
3444:   auto OwnedBytes = llvm::make_unique<StreamingMemoryObject>(
3446:   StreamingMemoryObject &Bytes = *OwnedBytes;
3447:   StreamFile = llvm::make_unique<BitstreamReader>(std::move(OwnedBytes));
355:   std::error_code InitStreamFromBuffer();
395:       TheModule(nullptr), Buffer(buffer), LazyStreamer(nullptr),
2131:         if (LazyStreamer && SeenValueSymbolTable) {
2299:         if (LazyStreamer)
2383:         if (LazyStreamer)
3417:   if (LazyStreamer)
3419:   return InitStreamFromBuffer();
3445:       std::move(LazyStreamer));
go.googlesource.com/grpc-review:transport/transport.go: [ master, ] go
165: type Stream struct {
309: func newContextWithStream(ctx context.Context, stream *Stream) context.Context {
314: func StreamFromContext(ctx context.Context) (s *Stream, ok bool) {
427: func StreamErrorf(c codes.Code, format string, a ...interface{}) StreamError {
455: type StreamError struct {
164: // Stream represents an RPC in the transport layer.
167: 	// nil for client side Stream.
208: func (s *Stream) RecvCompress() string {
213: func (s *Stream) SetSendCompress(str string) {
220: func (s *Stream) Header() (metadata.MD, error) {
232: func (s *Stream) Trailer() metadata.MD {
240: func (s *Stream) ServerTransport() ServerTransport {
245: func (s *Stream) Context() context.Context {
250: func (s *Stream) TraceContext(tr trace.Trace) {
255: func (s *Stream) Method() string {
260: func (s *Stream) StatusCode() codes.Code {
265: func (s *Stream) StatusDesc() string {
275: func (s *Stream) SetTrailer(md metadata.MD) error {
285: func (s *Stream) write(m recvMsg) {
289: // Read reads all the data available for this Stream from the transport and
293: func (s *Stream) Read(p []byte) (n int, err error) {
304: // The key to save transport.Stream in the context.
315: 	s, ok = ctx.Value(streamKey).(*Stream)
388: 	Write(s *Stream, data []byte, opts *Options) error
390: 	// NewStream creates a Stream for an RPC.
391: 	NewStream(ctx context.Context, callHdr *CallHdr) (*Stream, error)
397: 	CloseStream(stream *Stream, err error)
411: 	WriteStatus(s *Stream, statusCode codes.Code, statusDesc string) error
413: 	Write(s *Stream, data []byte, opts *Options) error
415: 	WriteHeader(s *Stream, md metadata.MD) error
417: 	HandleStreams(func(*Stream))
159: 	streamWriteDone             // EndStream sent
160: 	streamReadDone              // EndStream received
307: // newContextWithStream creates a new context from ctx and attaches stream
313: // StreamFromContext returns the stream saved in ctx.
393: 	// CloseStream clears the footprint of a stream when the stream is
395: 	// CloseStream is called. Must be called when a stream is finished
426: // StreamErrorf creates an StreamError with the specified error code and description.
428: 	return StreamError{
454: // StreamError is an error that only affects one stream within a connection.
460: func (e StreamError) Error() string {
464: // ContextErr converts the error from context package into a StreamError.
465: func ContextErr(err error) StreamError {
468: 		return StreamErrorf(codes.DeadlineExceeded, "%v", err)
470: 		return StreamErrorf(codes.Canceled, "%v", err)
476: // If it receives from ctx.Done, it returns 0, the StreamError for ctx.Err.
161: 	streamDone                  // sendDone and recvDone or RSTStreamFrame is sent or received.
330: func NewServerTransport(protocol string, conn net.Conn, maxStreams uint32, authInfo credentials.AuthInfo) (ServerTransport, error) {
331: 	return newHTTP2Server(conn, maxStreams, authInfo)
416: 	// HandleStreams receives incoming streams using the given handler.
android.googlesource.com/platform/superproject:external/mesa3d/include/D3D9/d3d9types.h: [ master, ] c++
1751:     WORD Stream;
android.googlesource.com/platform/external/mesa3d:include/D3D9/d3d9types.h: [ master, ] c++ Duplicate result
chromium.googlesource.com/crashpad/crashpad:third_party/cpp-httplib/cpp-httplib/httplib.h: [ master, ] c++
161: class Stream {
163:     virtual ~Stream() {}
173: class SocketStream : public Stream {
308: class SSLSocketStream : public Stream {
1388: inline SocketStream::SocketStream(socket_t sock): sock_(sock)
1392: inline SocketStream::~SocketStream()
2221: inline SSLSocketStream::SSLSocketStream(socket_t sock, SSL* ssl)
2226: inline SSLSocketStream::~SSLSocketStream()
221:     bool process_request(Stream& strm, bool last_connection, bool& connection_close);
237:     void write_response(Stream& strm, bool last_connection, const Request& req, Response& res);
292:     bool process_request(Stream& strm, Request& req, Response& res, bool& connection_close);
301:     bool read_response_line(Stream& strm, Response& res);
302:     void write_request(Stream& strm, Request& req);
386:     stream_line_reader(Stream& strm, char* fixed_buffer, size_t fixed_buffer_size)
442:     Stream& strm_;
761: inline bool read_headers(Stream& strm, Headers& headers)
788: inline bool read_content_with_length(Stream& strm, std::string& out, size_t len, Progress progress)
808: inline bool read_content_without_length(Stream& strm, std::string& out)
824: inline bool read_content_chunked(Stream& strm, std::string& out)
870: bool read_content(Stream& strm, T& x, Progress progress = Progress())
890: inline void write_headers(Stream& strm, const T& info)
1358: inline void Stream::write_format(const char* fmt, const Args& ...args)
1539: inline void Server::write_response(Stream& strm, bool last_connection, const Request& req, Response& res)
1750: inline bool Server::process_request(Stream& strm, bool last_connection, bool& connection_close)
1837:         [this](Stream& strm, bool last_connection, bool& connection_close) {
1881: inline bool Client::read_response_line(Stream& strm, Response& res)
1917: inline void Client::write_request(Stream& strm, Request& req)
1964: inline bool Client::process_request(Stream& strm, Request& req, Response& res, bool& connection_close)
2001:         [&](Stream& strm, bool /*last_connection*/, bool& connection_close) {
2292:         [this](Stream& strm, bool last_connection, bool& connection_close) {
2325:         [&](Stream& strm, bool /*last_connection*/, bool& connection_close) {
175:     SocketStream(socket_t sock);
176:     virtual ~SocketStream();
310:     SSLSocketStream(socket_t sock, SSL* ssl);
311:     virtual ~SSLSocketStream();
510:             SocketStream strm(sock);
522:         SocketStream strm(sock);
1396: inline int SocketStream::read(char* ptr, size_t size)
1401: inline int SocketStream::write(const char* ptr, size_t size)
1406: inline int SocketStream::write(const char* ptr)
1411: inline std::string SocketStream::get_remote_addr() {
2179:             SSLSocketStream strm(sock, ssl);
2191:         SSLSocketStream strm(sock, ssl);
2230: inline int SSLSocketStream::read(char* ptr, size_t size)
2235: inline int SSLSocketStream::write(const char* ptr, size_t size)
2240: inline int SSLSocketStream::write(const char* ptr)
2245: inline std::string SSLSocketStream::get_remote_addr() {
chromium.googlesource.com/native_client/pnacl-gcc:gcc/ada/g-socket.adb: [ master, ] ada
2305:    function Stream
2323:    function Stream (Socket : Socket_Type) return Stream_Access is
225:    type Stream_Socket_Stream_Type is new Root_Stream_Type with record
229:    type Stream_Socket_Stream_Access is
241:    procedure Stream_Write
2335:    procedure Stream_Write
205:    type Datagram_Socket_Stream_Type is new Root_Stream_Type with record
211:    type Datagram_Socket_Stream_Access is
75:              (Socket_Stream   => SOSC.SOCK_STREAM,
203:    --  Types needed for Datagram_Socket_Stream_Type
212:      access all Datagram_Socket_Stream_Type;
215:      (Stream : in out Datagram_Socket_Stream_Type;
216:       Item   : out Ada.Streams.Stream_Element_Array;
217:       Last   : out Ada.Streams.Stream_Element_Offset);
220:      (Stream : in out Datagram_Socket_Stream_Type;
221:       Item   : Ada.Streams.Stream_Element_Array);
223:    --  Types needed for Stream_Socket_Stream_Type
230:      access all Stream_Socket_Stream_Type;
233:      (Stream : in out Stream_Socket_Stream_Type;
234:       Item   : out Ada.Streams.Stream_Element_Array;
235:       Last   : out Ada.Streams.Stream_Element_Offset);
238:      (Stream : in out Stream_Socket_Stream_Type;
239:       Item   : Ada.Streams.Stream_Element_Array);
243:       Item   : Ada.Streams.Stream_Element_Array;
245:    --  Common implementation for the Write operation of Datagram_Socket_Stream_
246:    --  Type and Stream_Socket_Stream_Type.
831:       Mode   : Mode_Type   := Socket_Stream)
919:      (Stream : not null Stream_Access) return Sock_Addr_Type
922:       if Stream.all in Datagram_Socket_Stream_Type then
923:          return Datagram_Socket_Stream_Type (Stream.all).From;
925:          return Get_Peer_Name (Stream_Socket_Stream_Type (Stream.all).Socket);
1672:      (Stream : in out Datagram_Socket_Stream_Type;
1673:       Item   : out Ada.Streams.Stream_Element_Array;
1674:       Last   : out Ada.Streams.Stream_Element_Offset)
1676:       First : Ada.Streams.Stream_Element_Offset          := Item'First;
1677:       Index : Ada.Streams.Stream_Element_Offset          := First - 1;
1678:       Max   : constant Ada.Streams.Stream_Element_Offset := Item'Last;
1683:            (Stream.Socket,
1686:             Stream.From);
1704:      (Stream : in out Stream_Socket_Stream_Type;
1705:       Item   : out Ada.Streams.Stream_Element_Array;
1706:       Last   : out Ada.Streams.Stream_Element_Offset)
1708:       pragma Warnings (Off, Stream);
1710:       First : Ada.Streams.Stream_Element_Offset          := Item'First;
1711:       Index : Ada.Streams.Stream_Element_Offset          := First - 1;
1712:       Max   : constant Ada.Streams.Stream_Element_Offset := Item'Last;
1716:          Receive_Socket (Stream.Socket, Item (First .. Max), Index);
1734:       Item   : out Ada.Streams.Stream_Element_Array;
1735:       Last   : out Ada.Streams.Stream_Element_Offset;
1757:       Item   : out Ada.Streams.Stream_Element_Array;
1758:       Last   : out Ada.Streams.Stream_Element_Offset;
1793:       Count  : out Ada.Streams.Stream_Element_Count;
1825:       Count := Ada.Streams.Stream_Element_Count (Res);
2005:       Item   : Ada.Streams.Stream_Element_Array;
2006:       Last   : out Ada.Streams.Stream_Element_Offset;
2019:       Item   : Ada.Streams.Stream_Element_Array;
2020:       Last   : out Ada.Streams.Stream_Element_Offset;
2035:       Item   : Ada.Streams.Stream_Element_Array;
2036:       Last   : out Ada.Streams.Stream_Element_Offset;
2083:       Count  : out Ada.Streams.Stream_Element_Count;
2129:          Count := Count + Ada.Streams.Stream_Element_Count (Res);
2302:    -- Stream --
2307:       Send_To : Sock_Addr_Type) return Stream_Access
2309:       S : Datagram_Socket_Stream_Access;
2312:       S        := new Datagram_Socket_Stream_Type;
2316:       return Stream_Access (S);
2317:    end Stream;
2320:    -- Stream --
2324:       S : Stream_Socket_Stream_Access;
2326:       S := new Stream_Socket_Stream_Type;
2328:       return Stream_Access (S);
2329:    end Stream;
2332:    -- Stream_Write --
2337:       Item   : Ada.Streams.Stream_Element_Array;
2340:       First : Ada.Streams.Stream_Element_Offset;
2341:       Index : Ada.Streams.Stream_Element_Offset;
2342:       Max   : constant Ada.Streams.Stream_Element_Offset := Item'Last;
2366:    end Stream_Write;
2590:      (Stream : in out Datagram_Socket_Stream_Type;
2591:       Item   : Ada.Streams.Stream_Element_Array)
2594:       Stream_Write (Stream.Socket, Item, To => Stream.To'Unrestricted_Access);
2602:      (Stream : in out Stream_Socket_Stream_Type;
2603:       Item   : Ada.Streams.Stream_Element_Array)
2606:       Stream_Write (Stream.Socket, Item, To => null);
32: with Ada.Streams;              use Ada.Streams;
github.com/kubernetes/minikube:vendor/github.com/samalba/dockerclient/types.go: [ master, ] go
138: 	Stream bool
github.com/fuchsia-mirror/zircon:system/host/zbi/zbi.cpp: [ master, ] c++
1075:     void Stream(OutputStream* out) {
96: class OutputStream {
103:     explicit OutputStream(fbl::unique_fd fd) : fd_(std::move(fd)) {
106:     ~OutputStream() {
1437:     void StreamRawPayload(OutputStream* out) {
1444:     uint32_t StreamRaw(OutputStream* out) {
1452:     uint32_t StreamCompressed(OutputStream* out) {
1362:             item->Stream(&out);
98:     OutputStream() = delete;
100:     DISALLOW_COPY_AND_ASSIGN_ALLOW_MOVE(OutputStream);
101:     OutputStream(OutputStream&&) = default;
244:     OutputStream RawFile(const char* name) {
265:     OutputStream CreateFile(const char* outfile) {
283:         return OutputStream(std::move(fd));
425:     void Init(OutputStream* out, const zbi_header_t& header) {
465:     void Write(OutputStream* out, const iovec& input) {
474:     uint32_t Finish(OutputStream* out) {
529:     void WriteBuffer(OutputStream* out, Buffer buffer, size_t actual_size) {
1038:                 // We won't compute it until StreamCompressed, so
1072:     // Streaming exhausts the item's payload.  The OutputStream will now
1077:         uint32_t wrote = compress_ ? StreamCompressed(out) : StreamRaw(out);
1339:                 // The uncompressed item must outlive the OutputStream.
1341:                 uncompressed->StreamRawPayload(&out);
1344:                 StreamRawPayload(&out);
1359:             // The OutputStream stores pointers into Item buffers in its write
1448:         StreamRawPayload(out);
github.com/playgameservices/play-games-plugin-for-unity:source/PluginDev/Assets/GooglePlayGames/BasicApi/CommonTypes.cs: [ master, ] c#
124:         Stream = 1  // Not currently supported in the Unity Plugin.
chromium.googlesource.com/infra/luci/recipes-py:recipe_engine/stream.py: [ master, ] python
50:   class Stream(object):
149:   class Stream(StreamEngine.Stream):
218:   class Stream(StreamEngine.Stream):
277:   class Stream(StreamEngine.Stream):
49: class StreamEngine(object):
69:   class StepStream(Stream):
163:   class StepStream(Stream):
229:   class StepStream(Stream):
281:   class StepStream(Stream):
296: class StreamEngineInvariants(StreamEngine):
311:   class StepStream(StreamEngine.StepStream):
367:   class LogStream(StreamEngine.Stream):
435:   class StepStream(StreamEngine.StepStream):
494:   class StepLogStream(StreamEngine.Stream):
506:   class AllowSubannotationsStepStream(StepStream):
132: class ProductStreamEngine(StreamEngine):
199: class MultiStreamEngine(StreamEngine):
276: class NoopStreamEngine(StreamEngine):
390: class AnnotatorStreamEngine(StreamEngine):
16: Stream is a virtual well-behaved stream (associated with an Engine) which you
40:     stream (StreamEngine.Stream): The stream to output to.
172:       return ProductStreamEngine.Stream(
242:         return MultiStreamEngine.Stream(*log_streams)
283:       return NoopStreamEngine.Stream()
12: StreamEngine will coordinate the multiplexing of streams.  In the case of
103:     """Creates a new StepStream in this engine.
110:     is to implement an annotations parser that converts to StreamEngine calls;
133:   """A StreamEngine that forms the non-commutative product of two other
134:   StreamEngines.
136:   Because StreamEngine has no observations (i.e. it is an F-Algebra), we can
186:     return self.StepStream(
200:   """A StreamEngine consisting of one or more inner StreamEngines.
202:   A call to this StreamEngine will be distributed to the inner StreamEngines.
257:     return self.StepStream(
269:     assert isinstance(se, StreamEngine)
293:     return self.StepStream()
297:   """Checks that the users are using a StreamEngine hygenically.
299:   Multiply with actually functional StreamEngines so you don't have to check
313:       super(StreamEngineInvariants.StepStream, self).__init__()
335:       ret = self._engine.LogStream(self, log_name)
387:     return self.StepStream(self, step_config.name)
437:       super(AnnotatorStreamEngine.StepStream, self).__init__()
462:       return self._engine.StepLogStream(self, log_name)
524:       stream = self.AllowSubannotationsStepStream(self, outstream,
527:       stream = self.StepStream(self, outstream, step_config.name)
307:     """Returns (ProductStreamEngine): A product applying invariants to "other".
309:     return ProductStreamEngine(cls(), other)
399:     super(AnnotatorStreamEngine, self).open()
404:     super(AnnotatorStreamEngine, self).close()
android.googlesource.com/platform/external/cherry:third_party/sax/lib/sax.js: [ master, ] javascript
157:   var Stream = require("stream").Stream
159:   var Stream = function () {}
249:   return Stream.prototype.on.call(me, ev, handler)
167: function createStream (strict, opt) {
174:   Stream.apply(this)
213: SAXStream.prototype = Object.create(Stream.prototype,
6: sax.SAXStream = SAXStream
7: sax.createStream = createStream
168:   return new SAXStream(strict, opt)
171: function SAXStream (strict, opt) {
172:   if (!(this instanceof SAXStream)) return new SAXStream(strict, opt)
214:   { constructor: { value: SAXStream } })
216: SAXStream.prototype.write = function (data) {
232: SAXStream.prototype.end = function (chunk) {
238: SAXStream.prototype.on = function (ev, handler) {
github.com/apache/cordova-ios:node_modules/ios-sim/node_modules/nopt/lib/nopt.js: [ master, ] javascript
9:   , Stream = require("stream").Stream
21:   , Stream  : { type: Stream,  validate: validateStream  }
150: function validateStream (data, k, val) {
151:   if (!(val instanceof Stream)) return false
390:     , nullstream: [null, Stream]
404:     , logfd : [Number, Stream]
411:     , outfd : [Number, Stream]
github.com/apache/cordova-ios:node_modules/sax/lib/sax.js: [ master, ] javascript Duplicate result
github.com/apache/cordova-windows:node_modules/elementtree/node_modules/sax/lib/sax.js: [ master, ] javascript
160:   var Stream
164:     Stream = function () {}
261:     return Stream.prototype.on.call(me, ev, handler)
171:   function createStream (strict, opt) {
162:     Stream = require('stream').Stream
180:     Stream.apply(this)
221:   SAXStream.prototype = Object.create(Stream.prototype, {
4:   sax.SAXStream = SAXStream
5:   sax.createStream = createStream
172:     return new SAXStream(strict, opt)
175:   function SAXStream (strict, opt) {
176:     if (!(this instanceof SAXStream)) {
177:       return new SAXStream(strict, opt)
223:       value: SAXStream
227:   SAXStream.prototype.write = function (data) {
243:   SAXStream.prototype.end = function (chunk) {
251:   SAXStream.prototype.on = function (ev, handler) {
github.com/apache/trafficcontrol:traffic_ops/vendor/github.com/basho/riak-go-client/rpb/riak_kv/riak_kv.pb.go: [ master, ] go
585: 	Stream           *bool   `protobuf:"varint,2,opt,name=stream" json:"stream,omitempty"`
775: 	Stream       *bool                       `protobuf:"varint,8,opt,name=stream" json:"stream,omitempty"`
602: func (m *RpbListBucketsReq) GetStream() bool {
843: func (m *RpbIndexReq) GetStream() bool {
603: 	if m != nil && m.Stream != nil {
604: 		return *m.Stream
844: 	if m != nil && m.Stream != nil {
845: 		return *m.Stream
github.com/llvm-mirror/clang-tools-extra:clang-doc/BitcodeWriter.h: [ master, ] c++
162:     llvm::BitstreamWriter &Stream;
203:   llvm::BitstreamWriter &Stream;
161:   class StreamSubBlockGuard {
165:     StreamSubBlockGuard(llvm::BitstreamWriter &Stream_, BlockId ID)
176:     ~StreamSubBlockGuard() { Stream.ExitBlock(); }
130:   ClangDocBitcodeWriter(llvm::BitstreamWriter &Stream) : Stream(Stream) {
166:         : Stream(Stream_) {
169:       Stream.EnterSubblock(ID, BitCodeConstants::SubblockIDSize);
172:     StreamSubBlockGuard() = default;
173:     StreamSubBlockGuard(const StreamSubBlockGuard &) = delete;
174:     StreamSubBlockGuard &operator=(const StreamSubBlockGuard &) = delete;
github.com/apache/incubator-trafficcontrol:traffic_ops/vendor/github.com/basho/riak-go-client/rpb/riak_kv/riak_kv.pb.go: [ master, ] go Duplicate result
github.com/google/rspirv:spirv/spirv.rs: [ master, ] rust
426:     Stream = 29,
623:     GeometryStreams = 54,
894:     EmitStreamVertex = 220,
895:     EndStreamPrimitive = 221,
go.googlesource.com/perf:vendor/google.golang.org/grpc/transport/transport.go: [ master, ] go
167: type Stream struct {
339: func newContextWithStream(ctx context.Context, stream *Stream) context.Context {
344: func StreamFromContext(ctx context.Context) (s *Stream, ok bool) {
562: type StreamError struct {
361: 	MaxStreams   uint32
558: 	ErrStreamDrain = streamErrorf(codes.Unavailable, "the server stops accepting new RPCs")
166: // Stream represents an RPC in the transport layer.
169: 	// nil for client side Stream.
178: 	// cancel is always nil for client side Stream.
220: func (s *Stream) RecvCompress() string {
225: func (s *Stream) SetSendCompress(str string) {
231: func (s *Stream) Done() <-chan struct{} {
237: func (s *Stream) GoAway() <-chan struct{} {
244: func (s *Stream) Header() (metadata.MD, error) {
258: func (s *Stream) Trailer() metadata.MD {
266: func (s *Stream) ServerTransport() ServerTransport {
271: func (s *Stream) Context() context.Context {
276: func (s *Stream) Method() string {
281: func (s *Stream) StatusCode() codes.Code {
286: func (s *Stream) StatusDesc() string {
292: func (s *Stream) SetHeader(md metadata.MD) error {
307: func (s *Stream) SetTrailer(md metadata.MD) error {
317: func (s *Stream) write(m recvMsg) {
321: // Read reads all the data available for this Stream from the transport and
325: func (s *Stream) Read(p []byte) (n int, err error) {
334: // The key to save transport.Stream in the context.
345: 	s, ok = ctx.Value(streamKey{}).(*Stream)
451: 	Write(s *Stream, data []byte, opts *Options) error
453: 	// NewStream creates a Stream for an RPC.
454: 	NewStream(ctx context.Context, callHdr *CallHdr) (*Stream, error)
460: 	CloseStream(stream *Stream, err error)
479: // Write methods for a given Stream will be called serially.
482: 	HandleStreams(func(*Stream), func(context.Context, string) context.Context)
486: 	WriteHeader(s *Stream, md metadata.MD) error
490: 	Write(s *Stream, data []byte, opts *Options) error
495: 	WriteStatus(s *Stream, statusCode codes.Code, statusDesc string) error
161: 	streamWriteDone             // EndStream sent
162: 	streamReadDone              // EndStream received
337: // newContextWithStream creates a new context from ctx and attaches stream
343: // StreamFromContext returns the stream saved in ctx.
456: 	// CloseStream clears the footprint of a stream when the stream is
458: 	// CloseStream is called. Must be called when a stream is finished
509: // streamErrorf creates an StreamError with the specified error code and description.
510: func streamErrorf(c codes.Code, format string, a ...interface{}) StreamError {
511: 	return StreamError{
561: // StreamError is an error that only affects one stream within a connection.
567: func (e StreamError) Error() string {
571: // ContextErr converts the error from context package into a StreamError.
572: func ContextErr(err error) StreamError {
583: // If it receives from ctx.Done, it returns 0, the StreamError for ctx.Err.
585: // it return the StreamError for ctx.Err.
145: 		return 0, ErrStreamDrain
249: 		return nil, ErrStreamDrain
481: 	// HandleStreams receives incoming streams using the given handler.
556: 	// ErrStreamDrain indicates that the stream is rejected by the server because
586: // If it receives from goAway, it returns 0, ErrStreamDrain.
602: 		return 0, ErrStreamDrain
kernel.googlesource.com/pub/scm/linux/kernel/git/torvalds/linux:drivers/media/pci/ngene/ngene.h: [ master, ] c++
346: 	u8     Stream;             /* Stream number (UVI1, UVI2, TVOUT) */
572: 	u8  Stream;
676: 	u8                    Stream;
460: 		struct FW_STREAM_CONTROL         StreamControl;
550: 	StreamMode_NONE   = 0, /* Stream not used */
551: 	StreamMode_ANALOG = 1, /* Analog: Stream 0,1 = Video, 2,3 = Audio */
552: 	StreamMode_TSIN   = 2, /* Transport stream input (all) */
553: 	StreamMode_HDTV   = 4, /* HDTV: Maximum 1920x1080p30,1920x1080i60
555: 	StreamMode_TSOUT  = 8, /* Transport stream output (only stream 3) */
181: 	u32 Clock;           /* Stream time in 100ns units */
338: /* Meaning of FW_STREAM_CONTROL::Stream bits:
github.com/apache/cordova-lib:spec/plugman/projects/android/cordova/node_modules/sax/lib/sax.js: [ master, ] javascript Duplicate result
github.com/google/highwayhash:highwayhash/vector128.h: [ master, ] c++
709: HH_INLINE void Stream(const V128<T>& v, T* const HH_RESTRICT to) {
712: HH_INLINE void Stream(const V128<float>& v, float* const HH_RESTRICT to) {
715: HH_INLINE void Stream(const V128<double>& v, double* const HH_RESTRICT to) {
github.com/apache/falcon:falcon-ui/app/js/lib/dust-full-2.0.0.min.js: [ master, ] javascript
229:   function Stream() {
26:     var stream = new Stream();
40:       var master = callback ? new Stub(callback) : new Stream();
233:   Stream.prototype.flush = function() {
252:   Stream.prototype.emit = function(type, data) {
260:   Stream.prototype.on = function(type, callback) {
github.com/google/google-drive-shell-extension:google-drive-proxy/DriveProxy/API/Interfaces/IDriveService.cs: [ master, ] c#
2743:     protected class Stream : IStream
2749:       internal Stream()
2754:       internal Stream(DriveProxy.API.DriveService.Stream stream)
585:     IStream Stream { get; }
3167:       public IStream Stream
2760:       internal DriveProxy.API.DriveService.Stream _Stream
3160:       protected IStream _Stream = null;
66:     event IStreamEventHandler OnQueueStartedStream;
71:     event IStreamEventHandler OnQueueFinishedStream;
591:   public interface IStream
902:     private static void State_QueuedStream(DriveProxy.API.DriveService.State sender,
918:     private static void State_FinishedStream(DriveProxy.API.DriveService.State sender,
953:     public static IStream CreateStream()
1256:       public event IStreamEventHandler OnQueueStartedStream = null;
1257:       public event IStreamEventHandler OnQueueFinishedStream = null;
2293:       public void InvokeQueueStartedStream(object sender, IStreamEventArgs e)
2307:       public void InvokeQueueFinishedStream(object sender, IStreamEventArgs e)
3158:     protected class StreamEventArgs : IStreamEventArgs
3162:       public StreamEventArgs(IStream stream)
578:   public delegate void IStreamEventHandler(object sender, IStreamEventArgs e);
583:   public interface IStreamEventArgs
574:   ///   A delegate handler for Stream Events.
581:   ///   Arguments supplied for Stream Events.
903:                                            DriveProxy.API.DriveService.Stream stream)
909:           _DriveService.InvokeQueueStartedStream(sender, new StreamEventArgs(new Stream(stream)));
919:                                              DriveProxy.API.DriveService.Stream stream)
925:           _DriveService.InvokeQueueFinishedStream(sender, new StreamEventArgs(new Stream(stream)));
957:         return new Stream();
1755:           var tempStream = stream as Stream;
1775:           tempStream._Stream = copyStream;
1813:           var tempStream = stream as Stream;
1836:           tempStream._Stream = downloadStream;
1850:           var tempStream = stream as Stream;
1869:           tempStream._Stream = insertStream;
1924:           var tempStream = stream as Stream;
1944:           tempStream._Stream = moveStream;
1982:           var tempStream = stream as Stream;
2003:           tempStream._Stream = renameStream;
2041:           var tempStream = stream as Stream;
2064:           tempStream._Stream = uploadStream;
2102:           var tempStream = stream as Stream;
2121:           tempStream._Stream = trashStream;
2159:           var tempStream = stream as Stream;
2178:           tempStream._Stream = untrashStream;
2747:       private DriveProxy.API.DriveService.Stream _stream;
2757:         _Stream = stream;
2785:           if (_Stream == null)
2795:           _File._FileInfo = _Stream.FileInfo;
2805:           if (_Stream == null)
2810:           return _Stream.Type;
2818:           if (_Stream == null)
2823:           return _Stream.FileId;
2831:           if (_Stream == null)
2836:           return _Stream.FilePath;
2844:           if (_Stream == null)
2849:           return _Stream.FileName;
2857:           if (_Stream == null)
2862:           return _Stream.Title;
2870:           if (_Stream == null)
2875:           return _Stream.MimeType;
2883:           if (_Stream == null)
2888:           return _Stream.IsFolder;
2896:           if (_Stream == null)
2901:           return _Stream.NotStarted;
2909:           if (_Stream == null)
2914:           return _Stream.Queued;
2922:           if (_Stream == null)
2927:           return _Stream.Starting;
2935:           if (_Stream == null)
2940:           return _Stream.Processing;
2948:           if (_Stream == null)
2953:           return _Stream.Cancelling;
2961:           if (_Stream == null)
2966:           return _Stream.Cancelled;
2974:           if (_Stream == null)
2979:           return _Stream.Completed;
2987:           if (_Stream == null)
2992:           return _Stream.Failed;
3000:           if (_Stream == null)
3005:           return _Stream.Started;
3013:           if (_Stream == null)
3018:           return _Stream.Processed;
3026:           if (_Stream == null)
3031:           return _Stream.Finished;
3039:           if (_Stream == null)
3044:           return _Stream.BytesProcessed;
3052:           if (_Stream == null)
3057:           return _Stream.TotalBytes;
3065:           if (_Stream == null)
3070:           return _Stream.ExceptionMessage;
3078:           if (_Stream == null)
3083:           return _Stream.PercentCompleted;
3091:           if (_Stream == null)
3096:           return _Stream.RemainingTime;
3107:         if (_Stream == null)
3112:         _Stream.Cancel();
3115:       private void stream_OnProgressStarted(DriveProxy.API.DriveService.Stream stream)
3129:       private void stream_OnProgressChanged(DriveProxy.API.DriveService.Stream stream)
3143:       private void stream_OnProgressFinished(DriveProxy.API.DriveService.Stream stream)
3164:         _Stream = stream;
3169:         get { return _Stream; }
200:     /// <param name="stream">The CopyStream for the requested file.</param>
203:     void CopyFile(IStream stream, string parentId, string fileId);
208:     /// <param name="stream">The CopyStream for the requested file.</param>
211:     void CopyFile(IStream stream, string parentId, IFile file);
216:     /// <param name="stream">The DownloadStream for the requested file.</param>
220:     void DownloadFile(IStream stream, string fileId, int chunkSize = 0, bool checkIfAlreadyDownloaded = true);
225:     /// <param name="stream">The DownloadStream for the requested file.</param>
229:     void DownloadFile(IStream stream, IFile file, int chunkSize = 0, bool checkIfAlreadyDownloaded = true);
234:     /// <param name="stream">The InsertStream for the new file.</param>
238:     void InsertFile(IStream stream, string parentId, string title, bool isFolder);
243:     /// <param name="stream">The InsertStream for the new file.</param>
247:     void InsertFile(IStream stream, IFile parent, string title, bool isFolder);
252:     /// <param name="stream">The MoveStream for the requested file.</param>
255:     void MoveFile(IStream stream, string parentId, string fileId);
260:     /// <param name="stream">The MoveStream for the requested file.</param>
263:     void MoveFile(IStream stream, string parentId, IFile file);
268:     /// <param name="stream">The RenameStream for the requested file.</param>
271:     void RenameFile(IStream stream, string fileId, string title);
276:     /// <param name="stream">The RenameStream for the requested file.</param>
279:     void RenameFile(IStream stream, IFile file, string title);
284:     /// <param name="stream">The UploadStream for the requested file.</param>
291:     void UploadFile(IStream stream, string fileId, int chunkSize = 0, bool checkIfAlreadyUploaded = true);
296:     /// <param name="stream">The UploadStream for the requested file.</param>
303:     void UploadFile(IStream stream, IFile file, int chunkSize = 0, bool checkIfAlreadyUploaded = true);
308:     /// <param name="stream">The TrashStream for the requested file.</param>
310:     void TrashFile(IStream stream, string fileId);
315:     /// <param name="stream">The TrashStream for the requested file.</param>
317:     void TrashFile(IStream stream, IFile file);
322:     /// <param name="stream">The UntrashStream for the requested file.</param>
324:     void UntrashFile(IStream stream, string fileId);
329:     /// <param name="stream">The UntrashStream for the requested file.</param>
331:     void UntrashFile(IStream stream, IFile file);
601:     StreamType Type { get; }
869:           DriveProxy.API.DriveService.State.OnQueuedStream +=
870:             State_QueuedStream;
871:           DriveProxy.API.DriveService.State.OnFinishedStream +=
872:             State_FinishedStream;
950:     ///   Creates a new IStream object.
952:     /// <returns>IStream object (see IStream for more information)</returns>
1727:       public void CopyFile(IStream stream, string parentId, string fileId)
1751:       public void CopyFile(IStream stream, string parentId, IFile file)
1757:           if (tempStream == null)
1759:             throw new Exception("IStream is null or an unexpected type.");
1770:           var copyStream = new API.DriveService.CopyStream();
1772:           copyStream.Init(parentId, tempFile._FileInfo);
1774:           tempStream._Service = this;
1777:           _service.CopyFile(copyStream);
1785:       public void DownloadFile(IStream stream, string fileId, int chunkSize = 0, bool checkIfAlreadyDownloaded = true)
1809:       public void DownloadFile(IStream stream, IFile file, int chunkSize = 0, bool checkIfAlreadyDownloaded = true)
1815:           if (tempStream == null)
1817:             throw new Exception("IStream is null or an unexpected type.");
1827:           var downloadStream = new API.DriveService.DownloadStream();
1828:           var parameters = new API.DriveService.DownloadStream.Parameters();
1833:           downloadStream.Init(tempFile._FileInfo, parameters);
1835:           tempStream._Service = this;
1838:           _service.DownloadFile(downloadStream);
1846:       public void InsertFile(IStream stream, string parentId, string title, bool isFolder)
1852:           if (tempStream == null)
1854:             throw new Exception("IStream is null or an unexpected type.");
1857:           var insertStream = new API.DriveService.InsertStream();
1866:           insertStream.Init(parentId, title, mimeType);
1868:           tempStream._Service = this;
1871:           _service.InsertFile(insertStream);
1879:       public void InsertFile(IStream stream, IFile parent, string title, bool isFolder)
1896:       public void MoveFile(IStream stream, string parentId, string fileId)
1920:       public void MoveFile(IStream stream, string parentId, IFile file)
1926:           if (tempStream == null)
1928:             throw new Exception("IStream is null or an unexpected type.");
1939:           var moveStream = new API.DriveService.MoveStream();
1941:           moveStream.Init(parentId, tempFile._FileInfo);
1943:           tempStream._Service = this;
1946:           _service.MoveFile(moveStream);
1954:       public void RenameFile(IStream stream, string fileId, string title)
1978:       public void RenameFile(IStream stream, IFile file, string title)
1984:           if (tempStream == null)
1986:             throw new Exception("IStream is null or an unexpected type.");
1997:           var renameStream = new API.DriveService.RenameStream();
2000:           renameStream.Init(tempFile._FileInfo, title, tempFile.MimeType);
2002:           tempStream._Service = this;
2005:           _service.RenameFile(renameStream);
2013:       public void UploadFile(IStream stream, string fileId, int chunkSize = 0, bool checkIfAlreadyUploaded = true)
2037:       public void UploadFile(IStream stream, IFile file, int chunkSize = 0, bool checkIfAlreadyUploaded = true)
2043:           if (tempStream == null)
2045:             throw new Exception("IStream is null or an unexpected type.");
2055:           var uploadStream = new API.DriveService.UploadStream();
2056:           var parameters = new API.DriveService.UploadStream.Parameters();
2061:           uploadStream.Init(tempFile._FileInfo, parameters);
2063:           tempStream._Service = this;
2066:           _service.UploadFile(uploadStream);
2074:       public void TrashFile(IStream stream, string fileId)
2098:       public void TrashFile(IStream stream, IFile file)
2104:           if (tempStream == null)
2106:             throw new Exception("IStream is null or an unexpected type.");
2116:           var trashStream = new API.DriveService.TrashStream();
2118:           trashStream.Init(tempFile._FileInfo);
2120:           tempStream._Service = this;
2123:           _service.TrashFile(trashStream);
2131:       public void UntrashFile(IStream stream, string fileId)
2155:       public void UntrashFile(IStream stream, IFile file)
2161:           if (tempStream == null)
2163:             throw new Exception("IStream is null or an unexpected type.");
2173:           var untrashStream = new API.DriveService.UntrashStream();
2175:           untrashStream.Init(tempFile._FileInfo);
2177:           tempStream._Service = this;
2180:           _service.UntrashFile(untrashStream);
2297:           if (OnQueueStartedStream != null)
2299:             OnQueueStartedStream(sender, e);
2311:           if (OnQueueFinishedStream != null)
2313:             OnQueueFinishedStream(sender, e);
2801:       public StreamType Type
2807:             return StreamType.Unknown;
3121:             OnProgressStarted(this, new StreamEventArgs(this));
3135:             OnProgressChanged(this, new StreamEventArgs(this));
3149:             OnProgressFinished(this, new StreamEventArgs(this));
721:     event IStreamEventHandler OnProgressStarted;
726:     event IStreamEventHandler OnProgressChanged;
731:     event IStreamEventHandler OnProgressFinished;
2777:       public event IStreamEventHandler OnProgressStarted = null;
2778:       public event IStreamEventHandler OnProgressChanged = null;
2779:       public event IStreamEventHandler OnProgressFinished = null;
github.com/google/shipshape:third_party/node/lib/node_modules/npm/node_modules/npmconf/config-defs.js: [ master, ] javascript
6:   , Stream = require("stream").Stream
49: nopt.typeDefs.Stream = { type: Stream, validate: validateStream }
42: function validateStream (data, k, val) {
43:   if (!(val instanceof Stream)) return false
72:     case Stream:
73:       log.warn("invalid config", "Must be an instance of the Stream class")
272:   , logstream : Stream
github.com/GoogleCloudPlatform/k8s-multicluster-ingress:vendor/k8s.io/kubernetes/staging/src/k8s.io/client-go/rest/request.go: [ master, ] go
562: func (r *Request) Stream() (io.ReadCloser, error) {
64: 	Stream() (io.ReadCloser, error)
558: // Stream formats and executes the request, and offers streaming of the response.
779: 			glog.V(2).Infof("Stream error %#v when reading response body, may be caused by closed connection.", err)
780: 			streamErr := fmt.Errorf("Stream error %#v when reading response body, may be caused by closed connection. Please retry.", err)
536: 	decoder := streaming.NewDecoder(framer, r.serializers.StreamingSerializer)
771: 		case http2.StreamError:
537: 	return watch.NewStreamWatcher(restclientwatch.NewDecoder(decoder, r.serializers.Decoder)), nil
github.com/apache/cordova-windows:node_modules/sax/lib/sax.js: [ master, ] javascript Duplicate result
github.com/GoogleCloudPlatform/container-diff:vendor/github.com/fsouza/go-dockerclient/container.go: [ master, ] go
1078: 	Stream bool
1425: 	Stream bool
1247: 	InputStream          io.Reader `json:"-" qs:"-"`
1271: 	OutputStream      io.Writer     `json:"-" qs:"-"`
1296: 	OutputStream io.Writer `json:"-"`
1407: 	InputStream  io.Reader `qs:"-"`
1408: 	OutputStream io.Writer `qs:"-"`
1409: 	ErrorStream  io.Writer `qs:"-"`
1473: 	OutputStream      io.Writer     `qs:"-"`
1474: 	ErrorStream       io.Writer     `qs:"-"`
1537: 	OutputStream      io.Writer
1121: 		err := c.stream("GET", fmt.Sprintf("/containers/%s/stats?stream=%v", opts.ID, opts.Stream), streamOptions{
1424: 	// Stream the response?
1122: 			rawJSONStream:     true,
1261: 		in:      opts.InputStream,
1285: 		stdout:            opts.OutputStream,
1327: 	_, err = io.Copy(opts.OutputStream, resp.Body)
1421: 	// Get container logs, sending it to OutputStream.
1427: 	// Attach to stdin, and use InputStream.
1430: 	// Attach to stdout, and use OutputStream.
1433: 	// Attach to stderr, and use ErrorStream.
1460: 		in:             opts.InputStream,
1461: 		stdout:         opts.OutputStream,
1462: 		stderr:         opts.ErrorStream,
1491: // the streams and send the containers stdout to LogsOptions.OutputStream, and
1492: // stderr to LogsOptions.ErrorStream.
1495: // LogsOptions.OutputStream. The caller can use libraries such as dlog
1509: 		stdout:            opts.OutputStream,
1510: 		stderr:            opts.ErrorStream,
1553: 		stdout:            opts.OutputStream,
android.googlesource.com/platform/external/jmonkeyengine:engine/src/core/com/jme3/scene/VertexBuffer.java: [ master, ] java
218:         Stream,
github.com/llvm-mirror/polly:include/polly/ScopInfo.h: [ master, ] c++
3199:   raw_ostream &Stream;
3195:   ScopInfoPrinterPass(raw_ostream &OS) : Stream(OS) {}
github.com/apache/cordova-lib:spec/cordova/fixtures/platforms/cordova-browser/node_modules/send/index.js: [ master, ] javascript
30: var Stream = require('stream')
96: function SendStream (req, path, options) {
97:   Stream.call(this)
170:  * Inherits from `Stream`.
173: util.inherits(SendStream, Stream)
505:  * @param {Stream} res
506:  * @return {Stream} res
783:  * Stream `path` to the response.
74:  * Return a `SendStream` for `req` and `path`.
79:  * @return {SendStream}
84:   return new SendStream(req, path, options)
88:  * Initialize a `SendStream` with the given `path`.
179:  * @return {SendStream}
183: SendStream.prototype.etag = deprecate.function(function etag (val) {
193:  * @return {SendStream}
197: SendStream.prototype.hidden = deprecate.function(function hidden (val) {
209:  * @return {SendStream}
213: SendStream.prototype.index = deprecate.function(function index (paths) {
224:  * @return {SendStream}
228: SendStream.prototype.root = function root (path) {
234: SendStream.prototype.from = deprecate.function(SendStream.prototype.root,
237: SendStream.prototype.root = deprecate.function(SendStream.prototype.root,
244:  * @return {SendStream}
248: SendStream.prototype.maxage = deprecate.function(function maxage (maxAge) {
267: SendStream.prototype.error = function error (status, err) {
303: SendStream.prototype.hasTrailingSlash = function hasTrailingSlash () {
314: SendStream.prototype.isConditionalGET = function isConditionalGET () {
328: SendStream.prototype.isPreconditionFailure = function isPreconditionFailure () {
357: SendStream.prototype.removeContentHeaderFields = function removeContentHeaderFields () {
375: SendStream.prototype.notModified = function notModified () {
389: SendStream.prototype.headersAlreadySent = function headersAlreadySent () {
403: SendStream.prototype.isCachable = function isCachable () {
416: SendStream.prototype.onStatError = function onStatError (error) {
436: SendStream.prototype.isFresh = function isFresh () {
450: SendStream.prototype.isRangeFresh = function isRangeFresh () {
475: SendStream.prototype.redirect = function redirect (path) {
510: SendStream.prototype.pipe = function pipe (res) {
607: SendStream.prototype.send = function send (path, stat) {
717: SendStream.prototype.sendFile = function sendFile (path) {
758: SendStream.prototype.sendIndex = function sendIndex (path) {
790: SendStream.prototype.stream = function stream (path, options) {
797:   var stream = fs.createReadStream(path, options)
834: SendStream.prototype.type = function type (path) {
861: SendStream.prototype.setHeader = function setHeader (path, stat) {
github.com/google/kmsan:drivers/media/pci/ngene/ngene.h: [ master, ] c++ Duplicate result
github.com/kubernetes/kompose:vendor/github.com/fsouza/go-dockerclient/container.go: [ master, ] go
847: 	Stream bool
1130: 	Stream bool
997: 	InputStream          io.Reader `json:"-" qs:"-"`
1019: 	OutputStream io.Writer `json:"-" qs:"-"`
1039: 	OutputStream io.Writer `json:"-"`
1122: 	InputStream  io.Reader `qs:"-"`
1123: 	OutputStream io.Writer `qs:"-"`
1124: 	ErrorStream  io.Writer `qs:"-"`
1187: 	OutputStream io.Writer `qs:"-"`
1188: 	ErrorStream  io.Writer `qs:"-"`
1239: 	OutputStream io.Writer
885: 		err := c.stream("GET", fmt.Sprintf("/containers/%s/stats?stream=%v", opts.ID, opts.Stream), streamOptions{
1129: 	// Stream the response?
886: 			rawJSONStream:  true,
1010: 		in: opts.InputStream,
1031: 		stdout:         opts.OutputStream,
1060: 	_, err = io.Copy(opts.OutputStream, resp.Body)
1126: 	// Get container logs, sending it to OutputStream.
1132: 	// Attach to stdin, and use InputStream.
1135: 	// Attach to stdout, and use OutputStream.
1138: 	// Attach to stderr, and use ErrorStream.
1175: 		in:             opts.InputStream,
1176: 		stdout:         opts.OutputStream,
1177: 		stderr:         opts.ErrorStream,
1213: 		stdout:         opts.OutputStream,
1214: 		stderr:         opts.ErrorStream,
1253: 		stdout:         opts.OutputStream,
github.com/google/capsicum-linux:drivers/media/pci/ngene/ngene.h: [ capsicum, ] c++
330: 	u8     Stream;             /* Stream number (UVI1, UVI2, TVOUT) */
556: 	u8  Stream;
658: 	u8                    Stream;
444: 		struct FW_STREAM_CONTROL         StreamControl;
534: 	StreamMode_NONE   = 0, /* Stream not used */
535: 	StreamMode_ANALOG = 1, /* Analog: Stream 0,1 = Video, 2,3 = Audio */
536: 	StreamMode_TSIN   = 2, /* Transport stream input (all) */
537: 	StreamMode_HDTV   = 4, /* HDTV: Maximum 1920x1080p30,1920x1080i60
539: 	StreamMode_TSOUT  = 8, /* Transport stream output (only stream 3) */
165: 	u32 Clock;           /* Stream time in 100ns units */
322: /* Meaning of FW_STREAM_CONTROL::Stream bits:
github.com/apache/cordova-blackberry:node_modules/xml2js/node_modules/sax/lib/sax.js: [ master, ] javascript Duplicate result
github.com/google/ktsan:drivers/media/pci/ngene/ngene.h: [ tsan, ] c++
334: 	u8     Stream;             /* Stream number (UVI1, UVI2, TVOUT) */
560: 	u8  Stream;
662: 	u8                    Stream;
448: 		struct FW_STREAM_CONTROL         StreamControl;
538: 	StreamMode_NONE   = 0, /* Stream not used */
539: 	StreamMode_ANALOG = 1, /* Analog: Stream 0,1 = Video, 2,3 = Audio */
540: 	StreamMode_TSIN   = 2, /* Transport stream input (all) */
541: 	StreamMode_HDTV   = 4, /* HDTV: Maximum 1920x1080p30,1920x1080i60
543: 	StreamMode_TSOUT  = 8, /* Transport stream output (only stream 3) */
169: 	u32 Clock;           /* Stream time in 100ns units */
326: /* Meaning of FW_STREAM_CONTROL::Stream bits:
github.com/google/google-drive-proxy:DriveProxy/API/Interfaces/IDriveService.cs: [ master, ] c# Duplicate result
github.com/googlearchive/net-chromeify:examples/server/bundle.js: [ master, ] javascript
1228: function Stream() {
1236: Stream.prototype.pipe = function(dest, options) {
401: var Stream = require('stream');
560: util.inherits(net.Socket, Stream);
1231: util.inherits(Stream, events.EventEmitter);
1232: module.exports = Stream;
1234: Stream.Stream = Stream;
github.com/chromium/crashpad:third_party/cpp-httplib/cpp-httplib/httplib.h: [ master, ] c++ Duplicate result
github.com/apache/cordova-browser:node_modules/sax/lib/sax.js: [ master, ] javascript Duplicate result
github.com/apache/cordova-wp8:node_modules/nopt/lib/nopt.js: [ master, ] javascript
9:   , Stream = require("stream").Stream
21:   , Stream  : { type: Stream,  validate: validateStream  }
169: function validateStream (data, k, val) {
170:   if (!(val instanceof Stream)) return false
android.googlesource.com/platform/bionic:libc/upstream-netbsd/lib/libc/isc/eventlib_p.h: [ master, ] c++
169: 	enum {  Accept, File, Stream, Timer, Wait, Free, Null  } type;
126: typedef struct evStream {
143: } evStream;
141: 	struct evStream	*prevDone, *nextDone;
142: 	struct evStream	*prev, *next;
173: 		struct {  evStream *this;  }			stream;
250: 	/* Streams. */
251: 	evStream	*streams;
252: 	evStream	*strDone, *strLast;
127: 	evStreamFunc	func;
github.com/googlearchive/todomvc-mongodb:node_modules/angular/node_modules/jsdom/lib/jsdom/level3/xpath.js: [ master, ] javascript
54:   var Stream = xpath.Stream = function Stream(str) {
62:   Stream.prototype = {
177:     Stream.prototype.re = re;
178:     Stream.prototype.startsWithNcNameRe = new RegExp('^' + ncNameChars);
179:     Stream.prototype.isQnameRe = new RegExp('^' + qNameChars + '$');
180:     Stream.prototype.isNumberRe = new RegExp('^' + numberChars + '$');
1667:     var stream = new Stream(expr);
1702:     var stream = new Stream(expression);