<s> from muntjac . terminal . stream_variable import IStreamingEndEvent , IStreamingErrorEvent , IStreamingProgressEvent , IStreamingStartEvent <EOL> from muntjac . terminal . gwt . server . abstract_streaming_event import AbstractStreamingEvent <EOL> class StreamingEndEventImpl ( AbstractStreamingEvent , IStreamingEndEvent ) : <EOL> def __init__ ( self , filename , typ , totalBytes ) : <EOL> super ( StreamingEndEventImpl , self ) . __init__ ( filename , typ , totalBytes , <EOL> totalBytes ) <EOL> class StreamingErrorEventImpl ( AbstractStreamingEvent , IStreamingErrorEvent ) : <EOL> def __init__ ( self , filename , typ , contentLength , bytesReceived , exception ) : <EOL> super ( StreamingErrorEventImpl , self ) . __init__ ( filename , typ , <EOL> contentLength , bytesReceived ) <EOL> self . _exception = exception <EOL> def getException ( self ) : <EOL> return self . _exception <EOL> class StreamingProgressEventImpl ( AbstractStreamingEvent , <EOL> IStreamingProgressEvent ) : <EOL> def __init__ ( self , filename , typ , contentLength , bytesReceived ) : <EOL> super ( StreamingProgressEventImpl , self ) . __init__ ( filename , typ , <EOL> contentLength , bytesReceived ) <EOL> class StreamingStartEventImpl ( AbstractStreamingEvent , IStreamingStartEvent ) : <EOL> def __init__ ( self , filename , typ , contentLength ) : <EOL> super ( StreamingStartEventImpl , self ) . __init__ ( filename , typ , <EOL> contentLength , <NUM_LIT:0> ) <EOL> self . _disposed = None <EOL> def disposeStreamVariable ( self ) : <EOL> self . _disposed = True <EOL> def isDisposed ( self ) : <EOL> return self . _disposed </s>
