src/core/probe.ts
Function probe
has 26 lines of code (exceeds 25 allowed). Consider refactoring. Open
Open
Observable.create((obs: Observer<Strings>) => {
const cfg = { ...DEFAULT_PROBE_CONFIG, ...(config || {}) }
const socket = createSocket({ type: 'udp4' })
const socketMessages$ = fromEvent<IMessage>(socket, 'message').pipe(map(a => a[0]), shareReplay(1))
const internalLimit = new Subject()