~/bend-docscommunity

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

type Read source · line 7 · raw

Type

type Cut source · line 11 · raw

Data

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.