OTPKit

import OTPKit

// create a new dispatch queue to receive delegate notifications
let queue = DispatchQueue(label: "com.danielmurfin.OTPKit.producerQueue")

// a unique identifier for this producer
let uniqueIdentifier = UUID()

// creates a new IPv4 only producer, which has a default priority of 120, and transmits changes every 10 ms
let producer = OTPProducer(name: "My Producer", cid: uniqueIdentifier, ipMode: ipv4Only, interface: "en0", priority: 120, interval: 10, delegateQueue: Self.delegateQueue)

// starts the producer transmitting network data
producer.start()

do {
   
    let address = try OTPAddress(1,2,10)

    // add a new point using the producer's default priority (120)
    try producer.addPoint(with: address, name: "My Point")

    // create a new position module with default values
    let module = OTPModulePosition()

    // add this module to all points with this address
    producer.addModule(module, toPoint: address)

} catch let error as OTPPointValidationError {
    
    // handle error
    print(error.logDescription)

} catch let error {

    // handle unknown error
    print(error)

}

// request producer delegate notifications
producer.setProducerDelegate(self)

// create a new dispatch queue to receive delegate notifications
let queue = DispatchQueue(label: "com.danielmurfin.OTPKit.consumerQueue")

// a unique identifier for this consumer
let uniqueIdentifier = UUID()

// observe the position and reference frame modules
let moduleTypes = [OTPModulePosition.self, OTPModuleReferenceFrame.self]

// creates a new IPv6 only consumer which observes systems 1 and 20 and receives delegate notifications a maximum of every 50 ms
let consumer = OTPConsumer(name: "My Consumer", cid: uniqueIdentifier, ipMode: ipv6Only, interface: "en0", moduleTypes: moduleTypes, observedSystems: [1,20], delegateQueue: Self.delegateQueue, delegateInterval: 50)

// starts the consumer transmitting network data
consumer.start()

// request consumer delegate notifications
consumer.setConsumerDelegate(self)