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.



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

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

Instance Method Details

#cleanup ⇒ Object 



23
24
25
 
# File 'lib/protobuf/nats/response_muxer_request.rb', line 23

def cleanup
  @muxer.cleanup(@token)
end

#next_message(timeout) ⇒ Object 



19
20
21
 
# File 'lib/protobuf/nats/response_muxer_request.rb', line 19

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

#publish(subject, data) ⇒ Object 



15
16
17
 
# File 'lib/protobuf/nats/response_muxer_request.rb', line 15

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