Class: Up::Client
- Inherits:
-
Object
- Object
- Up::Client
- Defined in:
- lib/up/client.rb,
ext/up_ext/up_ext.c
Instance Attribute Summary collapse
-
#env ⇒ Object
readonly
instance vars are set by the server.
-
#handler ⇒ Object
instance vars are set by the server.
-
#protocol ⇒ Object
readonly
instance vars are set by the server.
-
#timeout ⇒ Object
readonly
instance vars are set by the server.
Instance Method Summary collapse
- #close ⇒ Object
- #open? ⇒ Boolean
- #pending ⇒ Object
- #publish(channel, message) ⇒ Object
- #pubsub? ⇒ Boolean
- #subscribe(*args) ⇒ Object
- #unsubscribe(*args) ⇒ Object
- #write(rdata) ⇒ Object
Instance Attribute Details
#env ⇒ Object (readonly)
instance vars are set by the server
12 13 14 |
# File 'lib/up/client.rb', line 12 def env @env end |
#handler ⇒ Object
instance vars are set by the server
12 13 14 |
# File 'lib/up/client.rb', line 12 def handler @handler end |
#protocol ⇒ Object (readonly)
instance vars are set by the server
12 13 14 |
# File 'lib/up/client.rb', line 12 def protocol @protocol end |
#timeout ⇒ Object (readonly)
instance vars are set by the server
12 13 14 |
# File 'lib/up/client.rb', line 12 def timeout @timeout end |
Instance Method Details
#close ⇒ Object
441 442 443 444 |
# File 'ext/up_ext/up_ext.c', line 441 def close @open = false `#@ws?.close()` end |
#open? ⇒ Boolean
20 21 22 |
# File 'lib/up/client.rb', line 20 def open? @open end |
#pending ⇒ Object
449 450 451 452 |
# File 'ext/up_ext/up_ext.c', line 449 def pending return -1 unless @open `#@ws?.getBufferedAmount()` end |
#publish(channel, message) ⇒ Object
507 508 509 510 511 512 513 514 515 516 517 518 519 |
# File 'ext/up_ext/up_ext.c', line 507 def publish(channel, ) res = false %x{ if (!message.$$is_string) { message = JSON.stringify(message); } res = #@server?.publish(channel, message); if (#@worker) { process.send({c: channel, m: message}); } } res end |
#pubsub? ⇒ Boolean
24 25 26 |
# File 'lib/up/client.rb', line 24 def pubsub? true end |
#subscribe(*args) ⇒ Object
535 536 537 538 |
# File 'ext/up_ext/up_ext.c', line 535 def subscribe(channel, is_pattern = false, &block) @sub_block = block `#@ws?.subscribe(channel)` end |
#unsubscribe(*args) ⇒ Object
563 564 565 |
# File 'ext/up_ext/up_ext.c', line 563 def unsubscribe(channel, is_pattern = false) `#@ws?.unsubscribe(channel)` end |
#write(rdata) ⇒ Object
549 550 551 |
# File 'ext/up_ext/up_ext.c', line 549 def write(data) `#@ws?.send(data, false)` end |