akarnokd

/*
 * Copyright 2008-2014, David Karnok 
 * The file is part of the Open Imperium Galactica project.
 * 
 * The code should be distributed under the LGPL license.
 * See http://www.gnu.org/licenses/lgpl.html for details.
 */

package hu.openig.utils;

akarnokd

public final class OperatorDelay2<T> implements OnSubscribe<T> {
        final Observable<T> source;
        final long delay;
        final TimeUnit unit;
        final Scheduler scheduler;

        public Delay2(Observable<T> source, long delay, TimeUnit unit, Scheduler scheduler) {
            this.source = source;
            this.delay = delay;
            this.unit = unit;

akarnokd

/**
 * Copyright 2014 Netflix, Inc.
 * 
 * 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

akarnokd

# Run progress: 0,00% complete, ETA 00:00:30
# VM invoker: C:\Program Files\Java\jdk1.7.0_55\jre\bin\java.exe
# VM options: -Xmx512m -Dfile.encoding=windows-1250
# Fork: 1 of 1
# Warmup: 5 iterations, 1 s each
# Measurement: 5 iterations, 1 s each
# Threads: 1 thread, will synchronize iterations
# Benchmark mode: Average time, time/op
# Benchmark: rx.archive.schedulers.ComputationSchedulerPerf.run
# Parameters: (size = 1)

akarnokd

# Run progress: 0,00% complete, ETA 00:00:30
# VM invoker: C:\Program Files\Java\jdk1.7.0_55\jre\bin\java.exe
# VM options: -Xmx512m -Dfile.encoding=windows-1250
# Fork: 1 of 1
# Warmup: 5 iterations, 1 s each
# Measurement: 5 iterations, 1 s each
# Threads: 1 thread, will synchronize iterations
# Benchmark mode: Average time, time/op
# Benchmark: rx.archive.schedulers.ComputationSchedulerPerf.run
# Parameters: (size = 1)

akarnokd

# Run progress: 0,00% complete, ETA 00:01:00
# VM invoker: C:\Program Files\Java\jdk1.7.0_55\jre\bin\java.exe
# VM options: -Xmx1300m -Dfile.encoding=windows-1250
# Fork: 1 of 1
# Warmup: 5 iterations, 1 s each
# Measurement: 5 iterations, 1 s each
# Threads: 1 thread, will synchronize iterations
# Benchmark mode: Average time, time/op
# Benchmark: rx.schedulers.ComputationSchedulerPerf.observeOn
# Parameters: (size = 1)

akarnokd

# Run progress: 0,00% complete, ETA 00:01:00
# VM invoker: C:\Program Files\Java\jdk1.7.0_55\jre\bin\java.exe
# VM options: -Xmx1300m -Dfile.encoding=windows-1250
# Fork: 1 of 1
# Warmup: 5 iterations, 1 s each
# Measurement: 5 iterations, 1 s each
# Threads: 1 thread, will synchronize iterations
# Benchmark mode: Average time, time/op
# Benchmark: rx.schedulers.ComputationSchedulerPerf.observeOn
# Parameters: (size = 1)

akarnokd

# Run progress: 0,00% complete, ETA 00:01:00
# VM invoker: C:\Program Files\Java\jdk1.7.0_55\jre\bin\java.exe
# VM options: -Xmx3072m -Dfile.encoding=windows-1250
# Fork: 1 of 1
# Warmup: 5 iterations, 1 s each
# Measurement: 5 iterations, 1 s each
# Threads: 1 thread, will synchronize iterations
# Benchmark mode: Average time, time/op
# Benchmark: rx.schedulers.ComputationSchedulerPerf.observeOn
# Parameters: (size = 1)

akarnokd

 /**
  * Copyright 2014 Netflix, Inc.
  *
  * 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

akarnokd

/**
 * Copyright 2014 Netflix, Inc.
 *
 * 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