Class: Protobuf::Nats::ResponseMuxerRequest

Inherits:
Object
  • Object
show all
Defined in:
lib/protobuf/nats/response_muxer_request.rb

Instance Method Summary collapse

Constructor Details

#initialize(muxer, token) ⇒ ResponseMuxerRequest

Returns a new instance of ResponseMuxerRequest.



4
5
6
7
 
# File 'lib/protobuf/nats/response_muxer_request.rb', line 4

def initialize(muxer, token)
  @muxer = muxer
  @token = token
end

Instance Method Details

#cleanup ⇒ Object 



17
18
19
 
# File 'lib/protobuf/nats/response_muxer_request.rb', line 17

def cleanup
  @muxer.cleanup(@token)
end

#next_message(timeout) ⇒ Object 



13
14
15
 
# File 'lib/protobuf/nats/response_muxer_request.rb', line 13

def next_message(timeout)
  @muxer.next_message(@token, timeout)
end

#publish(subject, data) ⇒ Object 



9
10
11
 
# File 'lib/protobuf/nats/response_muxer_request.rb', line 9

def publish(subject, data)
  @muxer.publish(subject, data, @token)
end