Module

ZeroMQ

Package
purescript-zeromq
Repository
athanclark/purescript-zeromq

This module tries to be analogous to the zermq4-simple Haskell library.

#Socket Source

data Socket :: Type -> Type -> Location -> Type

#socket Source

socket :: forall from to loc. IsLegal from to => from -> to -> Effect (Socket from to loc)

#ZMQ_Option Source

#setOption Source

setOption :: forall from to loc. Socket from to loc -> ZMQ_Option -> Buffer -> Effect Unit

#getOption Source

getOption :: forall from to loc. Socket from to loc -> ZMQ_Option -> Effect (Maybe Buffer)

#bind' Source

bind' :: forall from to. Bindable from => Socket from to Bound -> String -> Aff Unit

#unbind Source

unbind :: forall from to. Bindable from => Socket from to Bound -> String -> Aff Unit

#bindSync Source

bindSync :: forall from to. Bindable from => Socket from to Bound -> String -> Effect Unit

#unbindSync Source

unbindSync :: forall from to. Bindable from => Socket from to Bound -> String -> Effect Unit

#connect Source

connect :: forall from to. Connectable from => Socket from to Connected -> String -> Effect Unit

#disconnect Source

disconnect :: forall from to. Connectable from => Socket from to Connected -> String -> Effect Unit

#subscribe Source

subscribe :: forall from to loc. Subscriber from => Socket from to loc -> String -> Effect Unit

#unsubscribe Source

unsubscribe :: forall from to loc. Subscriber from => Socket from to loc -> String -> Effect Unit

#Subscriber Source

class Subscriber from 

Instances

#monitor Source

monitor :: forall from to loc. Socket from to loc -> Milliseconds -> Int -> Effect Unit

#unmonitor Source

unmonitor :: forall from to loc. Socket from to loc -> Effect Unit

#addMonitorListener Source

addMonitorListener :: forall from to loc. Socket from to loc -> MonitorEvent -> (Foreign -> Effect Unit) -> Effect Unit

#removeAllMonitorListeners Source

removeAllMonitorListeners :: forall from to loc. Socket from to loc -> MonitorEvent -> Effect Unit

#Flag Source

newtype Flag

Instances

#sendMore Source

#dontWait Source

#close Source

close :: forall from to loc. Socket from to loc -> Effect Unit

#sendJson Source

sendJson :: forall from to aux a loc. Sendable from to aux => EncodeJson a => aux -> Socket from to loc -> a -> Effect Unit

#readJson Source

readJson :: forall from to aux loc a. Receivable from to aux => DecodeJson a => Socket from to loc -> Aff (Maybe { aux :: aux, msg :: a })

#readJson' Source

readJson' :: forall from to aux loc a. Receivable from to aux => DecodeJson a => Socket from to loc -> Aff (Maybe (Either String { aux :: aux, msg :: a }))

#addReceiveListener Source

addReceiveListener :: forall from to loc. Socket from to loc -> (Array Buffer -> Effect Unit) -> Effect Unit

#removeAllReceiveListeners Source

removeAllReceiveListeners :: forall from to loc. Socket from to loc -> Effect Unit

#proxy Source

proxy :: forall from1 to1 from2 to2 from3 to3 loc3. Socket from1 to1 Bound -> Socket from2 to2 Bound -> Maybe (Socket from3 to3 loc3) -> Effect Unit

#Location Source

#Bound Source

data Bound :: Location

#Connected Source

Modules
ZeroMQ