Skip to content

Commit 60b34f1

Browse files
committed
Bump emmett-core to 1.3
1 parent 14e0848 commit 60b34f1

File tree

4 files changed

+22
-6
lines changed

4 files changed

+22
-6
lines changed

emmett55/tools/__init__.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,2 +1,2 @@
1-
from .decorators import requires as requires, service as service
2-
from .pipes import ServicePipe as ServicePipe
1+
from .decorators import requires as requires, service as service, sse as sse, stream as stream
2+
from .pipes import ServicePipe as ServicePipe, StreamPipe as StreamPipe

emmett55/tools/decorators.py

Lines changed: 10 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
1-
from emmett_core.pipeline.dyn import requires as _requires, service as _service
1+
from emmett_core.pipeline.dyn import requires as _requires, service as _service, sse as _sse, stream as _stream
22

33
from ..pipeline import RequirePipe
4-
from .pipes import ServicePipeBuilder
4+
from .pipes import ServicePipeBuilder, SSEPipe, StreamPipe
55

66

77
class requires(_requires):
@@ -10,3 +10,11 @@ class requires(_requires):
1010

1111
class service(_service):
1212
_inner_builder = ServicePipeBuilder()
13+
14+
15+
class stream(_stream):
16+
_pipe_cls = StreamPipe
17+
18+
19+
class sse(_sse):
20+
_pipe_cls = SSEPipe

emmett55/tools/pipes.py

Lines changed: 9 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
from emmett_core.pipeline.dyn import ServicePipeBuilder as _ServicePipeBuilder
2-
from emmett_core.pipeline.extras import JSONPipe as _JSONPipe
2+
from emmett_core.pipeline.extras import JSONPipe as _JSONPipe, SSEPipe as _SSEPipe, StreamPipe as _StreamPipe
33

44
from ..ctx import current
55

@@ -8,6 +8,14 @@ class JSONPipe(_JSONPipe):
88
_current = current
99

1010

11+
class StreamPipe(_StreamPipe):
12+
_current = current
13+
14+
15+
class SSEPipe(_SSEPipe):
16+
_current = current
17+
18+
1119
class ServicePipeBuilder(_ServicePipeBuilder):
1220
_pipe_cls = {"json": JSONPipe}
1321

pyproject.toml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -34,7 +34,7 @@ classifiers = [
3434

3535
dependencies = [
3636
"click>=6.0",
37-
"emmett-core[granian,reload]~=1.2.0",
37+
"emmett-core[granian,reload]~=1.3.0",
3838
]
3939

4040
[project.optional-dependencies]

0 commit comments

Comments
 (0)