O object

Finagle

extends Object with Serializable

Supertypes

Object, Serializable

Members

private def 

allocate

[F] ( svc: Service[Request,Response] ) ( implicit  F: ConcurrentEffect[F] ) : F[Client[F]]

def 

fromHttp4sReq

[F] ( req: Request[F] ) ( implicit  F: Concurrent[F] ) : F[Request]

def 

fromHttp4sResponse

[F] ( resp: Response[F] ) ( implicit  evidence$3: Concurrent[F] ) : F[Response]

def 

mkClient

[F] ( dest: String ) ( implicit  F: ConcurrentEffect[F] ) : Resource[F,Client[F]]

def 

mkClient

[F] ( svc: Service[Request,Response] ) ( implicit  F: ConcurrentEffect[F] ) : Resource[F,Client[F]]

def 

mkService

[F] ( route: HttpApp[F] ) ( implicit  evidence$1: Functor[F] evidence$2: ConcurrentEffect[F] ) : Service[Request,Response]

private def 

streamBody

[F] ( body: Stream[F,Byte] writer: Writer[Buf] ) ( implicit  evidence$4: Async[F] ) : Stream[F,Unit]

private def 

toF

[F, A] ( f: Future[A] ) ( implicit  F: Async[F] ) : F[A]

private def 

toFuture

[F, A] ( f: Any[A] ) ( implicit  evidence$5: Effect[F] ) : Future[A]

def 

toHttp4sReq

[F] ( req: Request ) : Request[F]

def 

toHttp4sResp

[F] ( resp: Response ) : Response[F]

private def 

toStream

[F] ( buf: Buf ) : Stream[F,Byte]