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.
