add rich output support for slide notes
Docker server image / build-and-push (push) Successful in 3m2s
Docker server image / build-and-push (push) Successful in 3m2s
This commit is contained in:
@@ -7,6 +7,7 @@ from typing import Protocol
|
||||
|
||||
from connectrpc.client import ConnectClient, ConnectClientSync
|
||||
from connectrpc.code import Code
|
||||
from connectrpc.codec import Codec
|
||||
from connectrpc.compression import Compression
|
||||
from connectrpc.errors import ConnectError
|
||||
from connectrpc.interceptor import Interceptor, InterceptorSync
|
||||
@@ -34,7 +35,7 @@ class ConversionService(Protocol):
|
||||
|
||||
|
||||
class ConversionServiceASGIApplication(ConnectASGIApplication[ConversionService]):
|
||||
def __init__(self, service: ConversionService | AsyncGenerator[ConversionService], *, interceptors: Iterable[Interceptor]=(), read_max_bytes: int | None = None, compressions: Iterable[Compression] | None = None) -> None:
|
||||
def __init__(self, service: ConversionService | AsyncGenerator[ConversionService], *, interceptors: Iterable[Interceptor]=(), read_max_bytes: int | None = None, compressions: Iterable[Compression] | None = None, codecs: Iterable[Codec] | None = None) -> None:
|
||||
super().__init__(
|
||||
service=service,
|
||||
endpoints=lambda svc: {
|
||||
@@ -92,6 +93,7 @@ class ConversionServiceASGIApplication(ConnectASGIApplication[ConversionService]
|
||||
interceptors=interceptors,
|
||||
read_max_bytes=read_max_bytes,
|
||||
compressions=compressions,
|
||||
codecs=codecs,
|
||||
)
|
||||
|
||||
@property
|
||||
@@ -202,6 +204,9 @@ class ConversionServiceClient(ConnectClient):
|
||||
)
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
class ConversionServiceSync(Protocol):
|
||||
def create_conversion(self, request: officeconvertapi_dot_v1_dot_conversion__pb2.CreateConversionRequest, ctx: RequestContext) -> officeconvertapi_dot_v1_dot_conversion__pb2.CreateConversionResponse:
|
||||
raise ConnectError(Code.UNIMPLEMENTED, "Not implemented")
|
||||
@@ -216,7 +221,7 @@ class ConversionServiceSync(Protocol):
|
||||
|
||||
|
||||
class ConversionServiceWSGIApplication(ConnectWSGIApplication):
|
||||
def __init__(self, service: ConversionServiceSync, interceptors: Iterable[InterceptorSync]=(), read_max_bytes: int | None = None, compressions: Iterable[Compression] | None = None) -> None:
|
||||
def __init__(self, service: ConversionServiceSync, interceptors: Iterable[InterceptorSync]=(), read_max_bytes: int | None = None, compressions: Iterable[Compression] | None = None, codecs: Iterable[Codec] | None = None) -> None:
|
||||
super().__init__(
|
||||
endpoints={
|
||||
"/officeconvertapi.v1.ConversionService/CreateConversion": EndpointSync.unary(
|
||||
@@ -273,6 +278,7 @@ class ConversionServiceWSGIApplication(ConnectWSGIApplication):
|
||||
interceptors=interceptors,
|
||||
read_max_bytes=read_max_bytes,
|
||||
compressions=compressions,
|
||||
codecs=codecs,
|
||||
)
|
||||
|
||||
@property
|
||||
@@ -381,3 +387,5 @@ class ConversionServiceClientSync(ConnectClientSync):
|
||||
headers=headers,
|
||||
timeout_ms=timeout_ms,
|
||||
)
|
||||
|
||||
|
||||
|
||||
Reference in New Issue
Block a user