| 24 | } |
| 25 | |
| 26 | void Device::unsubscribe(Port* port) { |
| 27 | std::lock_guard<std::mutex> lock(processMutex); |
| 28 | auto it = subscribed.find(port); |
| 29 | if (it != subscribed.end()) |
| 30 | subscribed.erase(it); |
| 31 | } |
| 32 | |
| 33 | void Device::processBuffer(const float* input, int inputStride, float* output, int outputStride, int frames) { |
| 34 | // Zero output since Ports might not write to all elements, or no Ports exist |