arxiv.canonical.role.stream module¶

class arxiv.canonical.role.stream.Emitter[source]¶

Bases: arxiv.canonical.role.stream.StreamRole, abc.ABC

event_supported = ['emit']¶

class arxiv.canonical.role.stream.Listener[source]¶

Bases: arxiv.canonical.role.stream.StreamRole, abc.ABC

event_supported = ['listen']¶

on_event(event)[source]¶

Return type: None

class arxiv.canonical.role.stream.NoStream[source]¶: Bases: arxiv.canonical.role.stream.StreamRole, abc.ABC

class arxiv.canonical.role.stream.StreamRole[source]¶

Bases: abc.ABC

event_supported = []¶

set_stream(stream, sources, name='all')[source]¶

Return type: None

property stream¶

Type: rtype