Lubyk documentation

lmidi.In

:rawReceive (a, b, c)

local lmidi = require 'lmidi' local core = require 'lmidi.core' local lib = core.In

local Message = lmidi.Message local yield = coroutine.yield

local private = {} local lens, ignoreType local SPECIAL_TYPES = { sysex = true, time = true, sense = true, }

local new = lib.new local self = new() if port_or_name then self:openPort(port_or_name) end self.ignored_types = { sysex = true, time = true, sense = true, } return self end

local openPort = lib.openPort openPort(self, ...) private.start(self) end

local virtualPort = lib.virtualPort virtualPort(self, ...) private.start(self) end

function private:start() -- midi.In.mode == 'pull' is used when we do not have a scheduler and -- we pull messages from the queue by hand. if lib.mode == 'thread' then if not lens then lens = require 'lens' end self.thread = lens.Thread(function() -- Copy Node's error function (or global) into self local thread = self.thread local super = self.super local read_fd = self:fd() while true do if not super:hasMessage() then yield('read', read_fd) else self:rawReceive(super:pop()) end end end) -- Also use dub's error handler for errors in Lua during -- 'rawReceive'. self.thread.error = self._errfunc -- Restart on error. self.thread.restart = true end end

-- This is used when we run without a scheduler. local super = self.super while super:hasMessage() do self:rawReceive(super:pop()) end end

-- # Methods

local function ignoreType(self, type_name, value) assert(SPECIAL_TYPES[type_name], "'"..type_name.."' is not a valid special midi type (sysex, time, sense).") local ignored_types = self.ignored_types ignored_types[type_name] = value self:ignoreTypes(ignored_types.sysex, ignored_types.time, ignored_types.sense) end

-- Start receiving special type type_name ('sysex', 'time', 'sense'). ignoreType(self, type_name, false) end

-- Stop receiving special type type_name ('sysex', 'time', 'sense'). ignoreType(self, type_name, true) end

-- # Callbacks -- -- Default dummy function end

-- Default dummy function self:receive(Message(a, b, c)) end