Pinch.Transport

Documentation

data Transport

A bidirectional transport to readwrite messages fromto.

Constructors

Transport

Fields

• writeMessage :: Builder -> IO ()
• readMessage :: forall a. Get a -> IO (ReadResult a)

framedTransport :: Connection c => c -> IO Transport

Creates a thrift framed transport. See also https://github.com/apache/thrift/blob/master/doc/specs/thrift-rpc.md#framed-vs-unframed-transport.

unframedTransport :: Connection c => c -> IO Transport

Creates a thrift unframed transport. See also https://github.com/apache/thrift/blob/master/doc/specs/thrift-rpc.md#framed-vs-unframed-transport.

class Connection c where

Methods

cGetSome :: c -> Int -> IO ByteString

Gets up to n bytes. Returns an empty bytestring if EOF is reached.

cPut :: c -> ByteString -> IO ()

Writes the given bytestring.

Instances

Connection Handle

Defined in Pinch.Transport

Methods

cGetSome :: Handle -> Int -> IO ByteString

cPut :: Handle -> ByteString -> IO ()

Connection Socket

Defined in Pinch.Transport

Methods

cGetSome :: Socket -> Int -> IO ByteString

cPut :: Socket -> ByteString -> IO ()

data ReadResult a

Constructors

RRSuccess a

RRFailure String

RREOF

Instances

Show a => Show (ReadResult a)

Defined in Pinch.Transport

Methods

showsPrec :: Int -> ReadResult a -> ShowS

show :: ReadResult a -> String

showList :: [ReadResult a] -> ShowS

Eq a => Eq (ReadResult a)

Defined in Pinch.Transport

Methods

(==) :: ReadResult a -> ReadResult a -> Bool

(/=) :: ReadResult a -> ReadResult a -> Bool