Skip to content
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.

Sign up for GitHub

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

codec with status code #1

Closed
wants to merge 11 commits into from
Closed

codec with status code #1

Changes from all commits
Commits
Show all changes
11 commits
Select commit Hold shift + click to select a range
3a8ec3f
add support for codec with status code
varshith257 Jun 18, 2024
7e14e92
Update EndpointClient.scala
varshith257 Jun 18, 2024
680912e
Update EndpointClient.scala
varshith257 Jun 19, 2024
56fa372
initial changes
varshith257 Jun 25, 2024
f2a2c9c
Merge branch 'main' of https://github.com/zio/zio-http into fix-codec
varshith257 Jun 25, 2024
bbbdc10
Merge branch 'fix-codec' of https://github.com/varshith257/zio-http i…
varshith257 Jun 25, 2024
3bd27fd
Update EndpointClient.scala
varshith257 Jun 25, 2024
063ddf2
Update NettyBodyWriter.scala
varshith257 Jun 25, 2024
be0bb17
fix
varshith257 Jun 25, 2024
a95ae00
Merge branch 'fix-codec' of https://github.com/varshith257/zio-http i…
varshith257 Jun 25, 2024
cf519a2
better approach
varshith257 Jun 26, 2024
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
7 changes: 3 additions & 4 deletions zio-http-example/src/main/scala/example/ServerSentEventEndpoint.scala
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -18,15 +18,14 @@ object ServerSentEventEndpoint extends ZIOAppDefault {
val stream: ZStream[Any, Nothing, ServerSentEvent] =
ZStream.repeatWithSchedule(ServerSentEvent(ISO_LOCAL_TIME.format(LocalDateTime.now)), Schedule.spaced(1.second))

val sseEndpoint: Endpoint[Unit, Unit, ZNothing, ZStream[Any, Nothing, ServerSentEvent], None] =
Endpoint(Method.GET / "sse").outStream[ServerSentEvent]
val sseEndpoint: Endpoint[Unit, Unit, ZNothing, Response, None] =
Endpoint(Method.GET / "sse").out[Response]

val sseRoute = sseEndpoint.implementHandler(Handler.succeed(stream))
val sseRoute = sseEndpoint.implementHandler(Handler.succeed(Response.fromServerSentEvents(stream)))

val routes: Routes[Any, Response] = sseRoute.toRoutes

override def run: ZIO[Any with ZIOAppArgs with Scope, Any, Any] = {
Server.serve(routes).provide(Server.default).exitCode
}

}
Loading