org.red5.server.stream
public class FileStreamSource extends Object implements ISeekableStreamSource, Constants
Modifier and Type | Field and Description |
---|---|
protected static org.slf4j.Logger |
log
Logger
|
HANDSHAKE_SIZE, HEADER_CONTINUE, HEADER_NEW, HEADER_SAME_SOURCE, HEADER_TIMER_CHANGE, MEDIUM_INT_MAX, SO_CLIENT_CLEAR_DATA, SO_CLIENT_DELETE_DATA, SO_CLIENT_INITIAL_DATA, SO_CLIENT_SEND_MESSAGE, SO_CLIENT_STATUS, SO_CLIENT_UPDATE_ATTRIBUTE, SO_CLIENT_UPDATE_DATA, SO_CONNECT, SO_DELETE_ATTRIBUTE, SO_DISCONNECT, SO_SEND_MESSAGE, SO_SET_ATTRIBUTE, SOURCE_TYPE_LIVE, SOURCE_TYPE_VOD, TYPE_ABORT, TYPE_AGGREGATE, TYPE_AUDIO_DATA, TYPE_BYTES_READ, TYPE_CHUNK_SIZE, TYPE_CLIENT_BANDWIDTH, TYPE_EDGE_ORIGIN, TYPE_FLEX_MESSAGE, TYPE_FLEX_SHARED_OBJECT, TYPE_FLEX_STREAM_SEND, TYPE_INVOKE, TYPE_NOTIFY, TYPE_PING, TYPE_SERVER_BANDWIDTH, TYPE_SHARED_OBJECT, TYPE_STREAM_METADATA, TYPE_VIDEO_DATA
Constructor and Description |
---|
FileStreamSource(ITagReader reader)
Creates file stream source with tag reader
|
Modifier and Type | Method and Description |
---|---|
void |
close()
Closes tag reader
|
IRTMPEvent |
dequeue()
Get tag from queue and convert to message
|
boolean |
hasMore()
Is there something more to stream?
|
int |
seek(int ts)
Seek the stream source to timestamp ts (in milliseconds).
|
public FileStreamSource(ITagReader reader)
reader
- Tag readerpublic void close()
close
in interface IStreamSource
public IRTMPEvent dequeue()
dequeue
in interface IStreamSource
public boolean hasMore()
hasMore
in interface IStreamSource
true
if there's streamable data, false
otherwisepublic int seek(int ts)
seek
in interface ISeekableStreamSource
ts
- Timestamp to seek toCopyright © 2006-2012 The Red5 Project