Reference documentation and code samples for the gapic-common class Gapic::StreamInput.
Manages requests for an input stream and holds the stream open until #close is called.
Inherits
- Object
Methods
#<<
def <<(request) -> StreamInput
Alias Of: #push
Adds a request object to the stream.
Parameter
- request (Object)
Returns
- (StreamInput) — Returns self.
#append
def append(request) -> StreamInput
Alias Of: #push
Adds a request object to the stream.
Parameter
- request (Object)
Returns
- (StreamInput) — Returns self.
#close
def close() -> StreamInput
Closes the stream.
Returns
- (StreamInput) — Returns self.
#initialize
def initialize(*requests) -> StreamInput
Create a new input stream object to manage streaming requests and hold the stream open until #close is called.
Parameter
- requests (Object)
Returns
- (StreamInput) — a new instance of StreamInput
#push
def push(request) -> StreamInput
Adds a request object to the stream.
Parameter
- request (Object)
Returns
- (StreamInput) — Returns self.