-
Notifications
You must be signed in to change notification settings - Fork 412
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
convert ServerResponseHandler
to class.
#1086
Conversation
Codecov Report
@@ Coverage Diff @@
## main #1086 +/- ##
==========================================
+ Coverage 57.61% 57.64% +0.02%
==========================================
Files 73 73
Lines 2291 2290 -1
Branches 69 67 -2
==========================================
Hits 1320 1320
+ Misses 971 970 -1
Continue to review full report at Codecov.
|
@@ -13,9 +13,7 @@ import zio.{UIO, ZIO} | |||
import java.io.RandomAccessFile | |||
|
|||
@Sharable |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
@Sharable |
private[zhttp] trait ServerResponseHandler[R] { | ||
def serverTime: ServerTime | ||
val rt: HttpRuntime[R] | ||
private[zhttp] final class ServerResponseHandler[R](runtime: HttpRuntime[R], serverTime: ServerTime) { |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
private[zhttp] final class ServerResponseHandler[R](runtime: HttpRuntime[R], serverTime: ServerTime) { | |
private[zhttp] final class HttpResponseService[R](runtime: HttpRuntime[R], serverTime: ServerTime) { |
with ServerResponseHandler[R] { self => | ||
|
||
with WebSocketUpgrade[R] { self => | ||
type Ctx = ChannelHandlerContext |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
type Ctx = ChannelHandlerContext | |
type Ctx = ChannelHandlerContext | |
val responseService = new ServerResponseHandler[R](zExec, ServerTime.make) |
Need to think about the design a little bit more. |
fixes #1085