recv-packet ( connection -- ? )

Vocabulary

msgpack.rpc.private

Inputs

connection

an object

Outputs

?

an object

Definition

USING: accessors io.streams.duplex kernel msgpack.rpc ;

IN: msgpack.rpc.private

:: recv-packet ( connection -- ? )
    connection stream>> :> stream connection session>>
    :> session stream [ ?read-packet ] with-stream* dup
    [ [ session ] ] dip [ feed-packet t ] curry compose
    [ connection stop f ] if ;