Skip to content

Commit 2adfac5

Browse files
committed
to fix scheduler endpoints
1 parent 325dbcc commit 2adfac5

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

core/src/main/scala/app/softnetwork/scheduler/launch/SchedulerEndpoints.scala

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -5,6 +5,8 @@ import app.softnetwork.api.server.ApiEndpoints
55
import app.softnetwork.persistence.schema.SchemaProvider
66
import app.softnetwork.scheduler.service.SchedulerServiceEndpoints
77
import app.softnetwork.session.service.SessionEndpoints
8+
import sttp.capabilities.WebSockets
9+
import sttp.capabilities.akka.AkkaStreams
810
import sttp.tapir.server.ServerEndpoint
911

1012
import scala.concurrent.Future
@@ -16,6 +18,7 @@ trait SchedulerEndpoints extends ApiEndpoints with SchedulerGuardian { _: Schema
1618
def schedulerEndpoints: ActorSystem[_] => SchedulerServiceEndpoints = system =>
1719
SchedulerServiceEndpoints.apply(system, sessionEndpoints(system))
1820

19-
override def endpoints: ActorSystem[_] => List[ServerEndpoint[Any, Future]] = system =>
21+
override def endpoints
22+
: ActorSystem[_] => List[ServerEndpoint[AkkaStreams with WebSockets, Future]] = system =>
2023
schedulerEndpoints(system).endpoints
2124
}

0 commit comments

Comments
 (0)