Mpv.SocketQueues

Documentation

messageLines :: ByteString -> ([ByteString], ByteString)

parseInMessage :: ByteString -> InMessage Value

publishAsInMessage :: Member (Queue (InMessage Value)) r => ByteString -> Sem r ()

concatMessages :: ByteString -> [ByteString] -> ByteString -> (ByteString, [ByteString])

accumulateMessages :: ByteString -> ByteString -> (ByteString, [ByteString])

readQueue :: forall r. Members [Queue (InMessage Value), Embed IO] r => Socket -> Sem r ()

writeQueue :: forall r. Members [Queue (OutMessage Value), Log, Embed IO] r => Socket -> Sem r ()

interpretQueues :: Members [Resource, Race, Embed IO] r => TBMQueue (OutMessage fmt) -> TBMQueue (InMessage fmt) -> InterpretersFor [Queue (InMessage fmt), Queue (OutMessage fmt)] r

withSocketQueues :: Members [Resource, Async, Race, Log, Embed IO] r => MpvResources Value -> InterpretersFor [Queue (InMessage Value), Queue (OutMessage Value)] r