midi_stream.hpp

#pragma once
#include <ossia/detail/config.hpp>
 
#include <ossia/detail/lockfree_queue.hpp>
 
#include <libremidi/message.hpp>
#include <libremidi/ump.hpp>
 
#include <optional>
 
namespace libremidi
{
class midi_in;
}
 
namespace ossia::net
{
class node_base;
}
 
namespace ossia::net::midi
{
class OSSIA_EXPORT midi_stream
{
public:
  static constexpr std::size_t queue_capacity = 2048;
 
  virtual ~midi_stream();
 
  ossia::spsc_queue<libremidi::ump> messages{queue_capacity};
 
  bool receive_ump(const libremidi::ump& m) noexcept { return messages.try_enqueue(m); }
 
  virtual libremidi::midi_in* midi_in() const noexcept = 0;
 
  virtual void enable_registration() = 0;
 
  virtual void push_value(const libremidi::ump&) = 0;
 
  virtual void push_value(const libremidi::message&) = 0;
 
  virtual std::optional<int> stream_channel(const node_base& n) const noexcept;
};
}