i} ZddlZddlZddlmZddlmZddlmZddlm Z Gdde Z y) N)Any)InvocationClientStreamMessage)StreamItemMessage)CompletionClientStreamMessagec4eZdZdZdZdZdefdZdZdZ y) SubjectaWClient to server streaming https://docs.microsoft.com/en-gb/aspnet/core/signalr/streaming?view=aspnetcore-5.0#client-to-server-streaming items = list(range(0,10)) subject = Subject() connection.send("UploadStream", subject) while(len(self.items) > 0): subject.next(str(self.items.pop())) subject.complete() cd|_d|_ttj|_t j|_d|_ y)N ) connectiontargetstruuiduuid4 invocation_id threadingLocklock_timeoutselfs L/home/work/apex_v16/venv/lib/python3.12/site-packages/signalrcore/subject.py__init__zSubject.__init__s8  .NN$  cb|j|j |j tdy)zEnsures that invocation streaming object is correct Raises: ValueError: if object is not valid, exception will be raised Nz`subject must be passed as an argument to a send function. hub_connection.send([method],[subject])r r r ValueErrorrs rcheckz Subject.checks; ?? ";;&%%-;< <.ritemc$|j|jj|jsJd|jj j t|j||jjy)zgSend next item to the server Args: item (any): Item that will be streamed timeoutzNext raised exceptionN) rracquirerr transportsendrrrelease)rrs rnextz Subject.next(st yy   7 $ # $7 !!&&'8""(  rc<|j|jj|jsJd|jj j t|jg|jg|jjy)zStarts streaming r zStart raised exceptionN) rrr"rr r#r$rrr r%rs rstartz Subject.start6s~ yy   7 % $ %7 !!&&-''(KK  rc"|j|jj|jsJd|jj j t|j|jjy)zFinish streaming r zComplete raised exceptionN) rrr"rr r#r$rrr%rs rcompletezSubject.completeCso yy   7 ( ' (7 !!&&'D""($ % rN) __name__ __module__ __qualname____doc__rrrr&r(r*rrr r s' <   rr ) rrtypingrmessages.invocation_messagermessages.stream_item_messagermessages.completion_messagerobjectr r/rrr5s% F;FBfBr