AdamChlupacek on upgrade-to-fs2.3
Address review comments, remove… (compare)
AdamChlupacek on upgrade-to-fs2.3
Fix travis dependencies. (compare)
AdamChlupacek on 0.5
Fix travis dependencies. (compare)
AdamChlupacek on upgrade-to-fs2.3
Setting version to 0.4.0-SNAPSH… Updated to fs2 1.0.0 final Fixes #29 and 16 more (compare)
AdamChlupacek on 0.5
Merge branch 'series/0.4' of gi… (compare)
AdamChlupacek on upgrade-to-fs2.3
Migrate fs2-http to fs2 2.3.0 +… (compare)
hi everyone,
I am trying to transform the stream response to an effect response like below
httpClient.request(request).compile.lastOrError
I am trying to keep the http responses as effect if possible. I want to use fs2-http
for websocket as well, that's why even though in some places i need to lift it to stream it makes more sense to me to keep it as effect first. But when I do that I am having the exception below on any http request.
java.nio.channels.ClosedChannelException: null
at java.base/sun.nio.ch.AsynchronousSocketChannelImpl.read(AsynchronousSocketChannelImpl.java:234)
at java.base/sun.nio.ch.AsynchronousSocketChannelImpl.read(AsynchronousSocketChannelImpl.java:298)
at fs2.io.tcp.Socket$.$anonfun$apply$3(Socket.scala:283)
at fs2.io.tcp.Socket$.$anonfun$apply$3$adapted(Socket.scala:276)
maybe it is not intended to evaluate that way, is it possible to use this way?
I was checking client side web sockets. I can see there is a parameter for pinging in server function but it is not exposed in client side
WebSocket:112
case None => (body through impl.webSocketOf(pipe, Duration.Undefined, maxFrameSize, client2Server = true) through socket.writes(None)).drain ++ emit(None)
Is there a way I am missing?
publishLocal
it for 2.13