// Path: dnssd/src/main/java/com/github/druk/dnssd/BrowseListener.java
// public interface BrowseListener extends BaseListener {
// 	/** Called to report discovered services.<P>
// 
// 		@param	browser
// 					The active browse service.
// 		<P>
// 		@param	flags
// 					Possible values are DNSSD.MORE_COMING.
// 		<P>
// 		@param	ifIndex
// 					The interface on which the service is advertised. This index should be passed
// 					to {@link InternalDNSSD#resolve} when resolving the service.
// 		<P>
// 		@param	serviceName
// 					The service name discovered.
// 		<P>
// 		@param	regType
// 					The registration type, as passed in to DNSSD.browse().
// 		<P>
// 		@param	domain
// 					The domain in which the service was discovered.
// 	*/
// 	void serviceFound(DNSSDService browser, int flags, int ifIndex, String serviceName, String regType, String domain);
// 
// 	/** Called to report services which have been deregistered.<P> 
// 
// 		@param	browser
// 					The active browse service.
// 		<P>
// 		@param	flags
// 					Possible values are DNSSD.MORE_COMING.
// 		<P>
// 		@param	ifIndex
// 					The interface on which the service is advertised.
// 		<P>
// 		@param	serviceName
// 					The service name which has deregistered.
// 		<P>
// 		@param	regType
// 					The registration type, as passed in to DNSSD.browse().
// 		<P>
// 		@param	domain
// 					The domain in which the service was discovered.
// 	*/
// 	void serviceLost(DNSSDService browser, int flags, int ifIndex, String serviceName, String regType, String domain);
// }
// 
// Path: dnssd/src/main/java/com/github/druk/dnssd/DNSSDService.java
// public interface	DNSSDService
// {
// 	/**
// 	Halt the active operation and free resources associated with the DNSSDService.<P>
// 
// 	Any services or records registered with this DNSSDService will be deregistered. Any
// 	Browse, Resolve, or Query operations associated with this reference will be terminated.<P>
// 
// 	Note: if the service was initialized with DNSSD.register(), and an extra resource record was
// 	added to the service via {@link DNSSDRegistration#addRecord}, the DNSRecord so created
// 	is invalidated when this method is called - the DNSRecord may not be used afterward.
// 	*/
// 	void		stop();
// } 


import com.github.druk.dnssd.BrowseListener;
import com.github.druk.dnssd.DNSSDService;
import io.reactivex.FlowableEmitter;
/*
 * Copyright (C) 2016 Andriy Druk
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *      http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */
package com.github.druk.rx2dnssd;



class Rx2BrowseListener implements BrowseListener {
    private final FlowableEmitter<? super BonjourService> emitter;

    Rx2BrowseListener(FlowableEmitter<? super BonjourService> emitter) {
        this.emitter = emitter;
    }

    @Override
    public void serviceFound(DNSSDService browser, int flags, int ifIndex, String serviceName, String regType, String domain) {
        if (emitter.isCancelled()) {
            return;
        }
        BonjourService service = new BonjourService.Builder(flags, ifIndex, serviceName, regType, domain).build();
        emitter.onNext(service);
    }

    @Override
    public void serviceLost(DNSSDService browser, int flags, int ifIndex, String serviceName, String regType, String domain) {
        if (emitter.isCancelled()) {
// Path: dnssd/src/main/java/com/github/druk/dnssd/BrowseListener.java
// public interface BrowseListener extends BaseListener {
// 	/** Called to report discovered services.<P>
// 
// 		@param	browser
// 					The active browse service.
// 		<P>
// 		@param	flags
// 					Possible values are DNSSD.MORE_COMING.
// 		<P>
// 		@param	ifIndex
// 					The interface on which the service is advertised. This index should be passed
// 					to {@link InternalDNSSD#resolve} when resolving the service.
// 		<P>
// 		@param	serviceName
// 					The service name discovered.
// 		<P>
// 		@param	regType
// 					The registration type, as passed in to DNSSD.browse().
// 		<P>
// 		@param	domain
// 					The domain in which the service was discovered.
// 	*/
// 	void serviceFound(DNSSDService browser, int flags, int ifIndex, String serviceName, String regType, String domain);
// 
// 	/** Called to report services which have been deregistered.<P> 
// 
// 		@param	browser
// 					The active browse service.
// 		<P>
// 		@param	flags
// 					Possible values are DNSSD.MORE_COMING.
// 		<P>
// 		@param	ifIndex
// 					The interface on which the service is advertised.
// 		<P>
// 		@param	serviceName
// 					The service name which has deregistered.
// 		<P>
// 		@param	regType
// 					The registration type, as passed in to DNSSD.browse().
// 		<P>
// 		@param	domain
// 					The domain in which the service was discovered.
// 	*/
// 	void serviceLost(DNSSDService browser, int flags, int ifIndex, String serviceName, String regType, String domain);
// }
// 
// Path: dnssd/src/main/java/com/github/druk/dnssd/DNSSDService.java
// public interface	DNSSDService
// {
// 	/**
// 	Halt the active operation and free resources associated with the DNSSDService.<P>
// 
// 	Any services or records registered with this DNSSDService will be deregistered. Any
// 	Browse, Resolve, or Query operations associated with this reference will be terminated.<P>
// 
// 	Note: if the service was initialized with DNSSD.register(), and an extra resource record was
// 	added to the service via {@link DNSSDRegistration#addRecord}, the DNSRecord so created
// 	is invalidated when this method is called - the DNSRecord may not be used afterward.
// 	*/
// 	void		stop();
// } 


// Path: rx2dnssd/src/main/java/com/github/druk/rx2dnssd/Rx2BrowseListener.java
import com.github.druk.dnssd.BrowseListener;
import com.github.druk.dnssd.DNSSDService;
import io.reactivex.FlowableEmitter;

/*
 * Copyright (C) 2016 Andriy Druk
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *      http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */
package com.github.druk.rx2dnssd;



class Rx2BrowseListener implements BrowseListener {
    private final FlowableEmitter<? super BonjourService> emitter;

    Rx2BrowseListener(FlowableEmitter<? super BonjourService> emitter) {
        this.emitter = emitter;
    }

    @Override
    public void serviceFound(DNSSDService browser, int flags, int ifIndex, String serviceName, String regType, String domain) {
        if (emitter.isCancelled()) {
            return;
        }
        BonjourService service = new BonjourService.Builder(flags, ifIndex, serviceName, regType, domain).build();
        emitter.onNext(service);
    }

    @Override
    public void serviceLost(DNSSDService browser, int flags, int ifIndex, String serviceName, String regType, String domain) {
        if (emitter.isCancelled()) {
            return;