Module: NNQ

Defined in:
lib/nnq/cli.rb,
lib/nnq/cli.rb,
lib/nnq/cli/bus.rb,
lib/nnq/cli/pair.rb,
lib/nnq/cli/pipe.rb,
lib/nnq/cli/term.rb,
lib/nnq/cli/config.rb,
lib/nnq/cli/pub_sub.rb,
lib/nnq/cli/req_rep.rb,
lib/nnq/cli/version.rb,
lib/nnq/cli/formatter.rb,
lib/nnq/cli/push_pull.rb,
lib/nnq/cli/cli_parser.rb,
lib/nnq/cli/base_runner.rb,
lib/nnq/cli/pipe_worker.rb,
lib/nnq/cli/socket_setup.rb,
lib/nnq/cli/ractor_helpers.rb,
lib/nnq/cli/transient_monitor.rb,
lib/nnq/cli/surveyor_respondent.rb,
lib/nnq/cli/expression_evaluator.rb

Overview

Forward-declare NNQ::Zstd::ProtocolError so the rescue clause below resolves even when compression wasn’t requested and ‘nnq/zstd` was never required. The real class is defined in nnq-zstd; re-opening it here with the same StandardError superclass is benign.

Defined Under Namespace

Modules: CLI, Zstd

Class Attribute Summary collapse

Class Method Summary collapse

Class Attribute Details

.incoming_proc ⇒ Proc? (readonly)

Returns registered incoming message transform.

Returns:

  • (Proc, nil) —

    registered incoming message transform



40
41
42
 
# File 'lib/nnq/cli.rb', line 40

def incoming_proc
  @incoming_proc
end

.outgoing_proc ⇒ Proc? (readonly)

Returns registered outgoing message transform.

Returns:

  • (Proc, nil) —

    registered outgoing message transform



38
39
40
 
# File 'lib/nnq/cli.rb', line 38

def outgoing_proc
  @outgoing_proc
end

Class Method Details

.incoming {|Array<String>| ... } ⇒ Proc

Registers an incoming message transform (used by -r scripts).

Yields:

  • (Array<String>) —

    1-element message array after receiving

Returns:

  • (Proc) 


52
 
# File 'lib/nnq/cli.rb', line 52

def incoming(&block) = @incoming_proc = block

.outgoing {|Array<String>| ... } ⇒ Proc

Registers an outgoing message transform (used by -r scripts).

Yields:

  • (Array<String>) —

    1-element message array before sending

Returns:

  • (Proc) 


46
 
# File 'lib/nnq/cli.rb', line 46

def outgoing(&block) = @outgoing_proc = block