package rx.internal.util;

import rx.Subscription;

public class SynchronizedSubscription implements Subscription {

    private final Subscription s;

    public SynchronizedSubscription(Subscription s) {
        this.s = s;
    }

    @Override
    public synchronized void unsubscribe() {
        s.unsubscribe();
    }

    @Override
    public synchronized boolean isUnsubscribed() {
        return s.isUnsubscribed();
    }

}

@@ -1,8 +1,596 @@
+/**%0A * Copyright 2014 Netflix, Inc.%0A * %0A * Licensed under the Apache License, Version 2.0 (the %22License%22); you may not use this file except in%0A * compliance with the License. You may obtain a copy of the License at%0A * %0A * http://www.apache.org/licenses/LICENSE-2.0%0A * %0A * Unless required by applicable law or agreed to in writing, software distributed under the License is%0A * distributed on an %22AS IS%22 BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See%0A * the License for the specific language governing permissions and limitations under the License.%0A */%0A
 package 

add license header