transport.bend fails
raw source on the hub · import 0xbfb6718181103ac566eb0ff5308d47ac/transport.bend as Transport
2 imports
import Base import ./json.bend as J
Types
type Connection source · line 4 · raw
Type
Connection@socket:Socket -> @buffered:String -> Connection
type Read source · line 7 · raw
Type
Frame@connection:Connection -> @value:0xbfb6718181103ac566eb0ff5308d47ac/json.Json -> Read
Broken@message:String -> Read
type Cut source · line 11 · raw
Data
Complete@line:String -> @rest:String -> Cut
PartialCut
Definitions
def cut source · line 15 · raw
@s:String -> @acc:String -> Cut
def broken source · line 21 · raw
@socket:Socket -> @message:String -> IO(Read)
def decoded source · line 26 · raw
@result:Result<&1, &1, String, 0xbfb6718181103ac566eb0ff5308d47ac/json.Json> -> @socket:Socket -> @rest:String -> IO(Read)
def chunk_nonempty source · line 31 · raw
@empty:Bool -> @socket:Socket -> @chunk:String -> @buffered:String -> @next:(@_:Connection -> IO(Read)) -> IO(Read)
def chunk source · line 37 · raw
@result:Pair(Socket, Result<&1, &1, Pair(U32, String), String>) -> @buffered:String -> @next:(@_:Connection -> IO(Read)) -> IO(Read)
def read_cut source · line 44 · raw
@part:Cut -> @socket:Socket -> @buffered:String -> @next:(@_:Connection -> IO(Read)) -> IO(Read)
def read_limit source · line 53 · raw
@large:Bool -> @socket:Socket -> @+buffered:String -> @next:(@_:Connection -> IO(Read)) -> IO(Read)
def sent source · line 66 · raw
@result:Pair(Socket, Result<&1, &1, Pair(U32, String), Unit>) -> IO(Result<&1, &1, String, Connection>)
def connected source · line 75 · raw
@result:Result<&1, &1, Pair(U32, String), Socket> -> @body:String -> IO(Result<&1, &1, String, Connection>)
def connect source · line 83 · raw
@port:U32 -> @body:String -> IO(Result<&1, &1, String, Connection>)
def close source · line 88 · raw
@connection:Connection -> IO(Unit)
Unsafe
unsafe read source · line 61 · raw
@connection:Connection -> IO(Read)
Socket progress depends on the external peer, not structural recursion.