class Sync
A synchronous wrapper for pipeline operations that executes one command at a time.
Definitionsdef initialize(pipeline)
Initialize a new sync wrapper.
Signaturepipeline
Pipeline
The pipeline to wrap.
def initialize(pipeline)
@pipeline = pipeline
end
def call(...)
This method just accumulates the commands and their params.
Implementationdef call(...)
@pipeline.call(...)
@pipeline.flush(1)
return @pipeline.read_response
end
RetroSearch is an open source project built by @garambo | Open a GitHub Issue
Search and Browse the WWW like it's 1997 | Search results from DuckDuckGo
HTML:
3.2
| Encoding:
UTF-8
| Version:
0.7.4