public static class LSL.StreamOutlet
extends java.lang.Object
Constructor and Description |
---|
LSL.StreamOutlet(LSL.StreamInfo info) |
LSL.StreamOutlet(LSL.StreamInfo info,
int chunk_size) |
LSL.StreamOutlet(LSL.StreamInfo info,
int chunk_size,
int max_buffered)
Establish a new stream outlet.
|
Modifier and Type | Method and Description |
---|---|
void |
close()
Close the outlet.
|
boolean |
have_consumers()
Check whether consumers are currently registered.
|
LSL.StreamInfo |
info()
Retrieve the stream info provided by this outlet.
|
void |
push_chunk(byte[] data) |
void |
push_chunk(byte[] data,
double timestamp) |
void |
push_chunk(byte[] data,
double[] timestamps) |
void |
push_chunk(byte[] data,
double[] timestamps,
boolean pushthrough) |
void |
push_chunk(byte[] data,
double timestamp,
boolean pushthrough) |
void |
push_chunk(double[] data) |
void |
push_chunk(double[] data,
double timestamp) |
void |
push_chunk(double[] data,
double[] timestamps) |
void |
push_chunk(double[] data,
double[] timestamps,
boolean pushthrough) |
void |
push_chunk(double[] data,
double timestamp,
boolean pushthrough) |
void |
push_chunk(float[] data) |
void |
push_chunk(float[] data,
double timestamp) |
void |
push_chunk(float[] data,
double[] timestamps) |
void |
push_chunk(float[] data,
double[] timestamps,
boolean pushthrough)
Push a chunk of multiplexed samples into the outlet.
|
void |
push_chunk(float[] data,
double timestamp,
boolean pushthrough)
Push a chunk of multiplexed samples into the outlet.
|
void |
push_chunk(int[] data) |
void |
push_chunk(int[] data,
double timestamp) |
void |
push_chunk(int[] data,
double[] timestamps) |
void |
push_chunk(int[] data,
double[] timestamps,
boolean pushthrough) |
void |
push_chunk(int[] data,
double timestamp,
boolean pushthrough) |
void |
push_chunk(short[] data) |
void |
push_chunk(short[] data,
double timestamp) |
void |
push_chunk(short[] data,
double[] timestamps) |
void |
push_chunk(short[] data,
double[] timestamps,
boolean pushthrough) |
void |
push_chunk(short[] data,
double timestamp,
boolean pushthrough) |
void |
push_chunk(java.lang.String[] data) |
void |
push_chunk(java.lang.String[] data,
double timestamp) |
void |
push_chunk(java.lang.String[] data,
double[] timestamps) |
void |
push_chunk(java.lang.String[] data,
double[] timestamps,
boolean pushthrough) |
void |
push_chunk(java.lang.String[] data,
double timestamp,
boolean pushthrough) |
void |
push_sample(byte[] data) |
void |
push_sample(byte[] data,
double timestamp) |
void |
push_sample(byte[] data,
double timestamp,
boolean pushthrough) |
void |
push_sample(double[] data) |
void |
push_sample(double[] data,
double timestamp) |
void |
push_sample(double[] data,
double timestamp,
boolean pushthrough) |
void |
push_sample(float[] data) |
void |
push_sample(float[] data,
double timestamp) |
void |
push_sample(float[] data,
double timestamp,
boolean pushthrough)
Push an array of values as a sample into the outlet.
|
void |
push_sample(int[] data) |
void |
push_sample(int[] data,
double timestamp) |
void |
push_sample(int[] data,
double timestamp,
boolean pushthrough) |
void |
push_sample(short[] data) |
void |
push_sample(short[] data,
double timestamp) |
void |
push_sample(short[] data,
double timestamp,
boolean pushthrough) |
void |
push_sample(java.lang.String[] data) |
void |
push_sample(java.lang.String[] data,
double timestamp) |
void |
push_sample(java.lang.String[] data,
double timestamp,
boolean pushthrough) |
boolean |
wait_for_consumers(double timeout)
Wait until some consumer shows up (without wasting resources).
|
public LSL.StreamOutlet(LSL.StreamInfo info, int chunk_size, int max_buffered)
info
- The stream information to use for creating this stream. Stays constant over the lifetime of the outlet.chunk_size
- Optionally the desired chunk granularity (in samples) for transmission. If unspecified,
each push operation yields one chunk. Inlets can override this setting.max_buffered
- Optionally the maximum amount of data to buffer (in seconds if there is a nominal
sampling rate, otherwise x100 in samples). The default is 6 minutes of data.public LSL.StreamOutlet(LSL.StreamInfo info, int chunk_size)
public LSL.StreamOutlet(LSL.StreamInfo info)
public void close()
public void push_sample(float[] data, double timestamp, boolean pushthrough)
data
- An array of values to push (one for each channel).timestamp
- Optionally the capture time of the sample, in agreement with local_clock(); if omitted, the current time is used.pushthrough
- Optionally whether to push the sample through to the receivers instead of buffering it with subsequent samples.
Note that the chunk_size, if specified at outlet construction, takes precedence over the pushthrough flag.public void push_sample(float[] data, double timestamp)
public void push_sample(float[] data)
public void push_sample(double[] data, double timestamp, boolean pushthrough)
public void push_sample(double[] data, double timestamp)
public void push_sample(double[] data)
public void push_sample(int[] data, double timestamp, boolean pushthrough)
public void push_sample(int[] data, double timestamp)
public void push_sample(int[] data)
public void push_sample(short[] data, double timestamp, boolean pushthrough)
public void push_sample(short[] data, double timestamp)
public void push_sample(short[] data)
public void push_sample(byte[] data, double timestamp, boolean pushthrough)
public void push_sample(byte[] data, double timestamp)
public void push_sample(byte[] data)
public void push_sample(java.lang.String[] data, double timestamp, boolean pushthrough)
public void push_sample(java.lang.String[] data, double timestamp)
public void push_sample(java.lang.String[] data)
public void push_chunk(float[] data, double timestamp, boolean pushthrough)
data
- A rectangular array of values for multiple samples.timestamp
- Optionally the capture time of the most recent sample, in agreement with local_clock(); if omitted, the current time is used.
The time stamps of other samples are automatically derived based on the sampling rate of the stream.pushthrough
- Optionally whether to push the chunk through to the receivers instead of buffering it with subsequent samples.
Note that the chunk_size, if specified at outlet construction, takes precedence over the pushthrough flag.public void push_chunk(float[] data, double timestamp)
public void push_chunk(float[] data)
public void push_chunk(double[] data, double timestamp, boolean pushthrough)
public void push_chunk(double[] data, double timestamp)
public void push_chunk(double[] data)
public void push_chunk(int[] data, double timestamp, boolean pushthrough)
public void push_chunk(int[] data, double timestamp)
public void push_chunk(int[] data)
public void push_chunk(short[] data, double timestamp, boolean pushthrough)
public void push_chunk(short[] data, double timestamp)
public void push_chunk(short[] data)
public void push_chunk(byte[] data, double timestamp, boolean pushthrough)
public void push_chunk(byte[] data, double timestamp)
public void push_chunk(byte[] data)
public void push_chunk(java.lang.String[] data, double timestamp, boolean pushthrough)
public void push_chunk(java.lang.String[] data, double timestamp)
public void push_chunk(java.lang.String[] data)
public void push_chunk(float[] data, double[] timestamps, boolean pushthrough)
data
- A rectangular array of values for multiple samples.timestamps
- An array of timestamp values holding time stamps for each sample in the data buffer.pushthrough
- Optionally whether to push the chunk through to the receivers instead of buffering it with subsequent samples.
Note that the chunk_size, if specified at outlet construction, takes precedence over the pushthrough flag.public void push_chunk(float[] data, double[] timestamps)
public void push_chunk(double[] data, double[] timestamps, boolean pushthrough)
public void push_chunk(double[] data, double[] timestamps)
public void push_chunk(int[] data, double[] timestamps, boolean pushthrough)
public void push_chunk(int[] data, double[] timestamps)
public void push_chunk(short[] data, double[] timestamps, boolean pushthrough)
public void push_chunk(short[] data, double[] timestamps)
public void push_chunk(byte[] data, double[] timestamps, boolean pushthrough)
public void push_chunk(byte[] data, double[] timestamps)
public void push_chunk(java.lang.String[] data, double[] timestamps, boolean pushthrough)
public void push_chunk(java.lang.String[] data, double[] timestamps)
public boolean have_consumers()
public boolean wait_for_consumers(double timeout)
public LSL.StreamInfo info()