Skip to content

Commit

Permalink
remove unused imports
Browse files Browse the repository at this point in the history
  • Loading branch information
xuwei-k committed Jul 8, 2018
1 parent 64f55f8 commit 1ab7f78
Show file tree
Hide file tree
Showing 13 changed files with 7 additions and 29 deletions.
4 changes: 0 additions & 4 deletions src/main/scala/rx/lang/scala/Observable.scala
Original file line number Diff line number Diff line change
Expand Up @@ -17,14 +17,11 @@
package rx.lang.scala

import rx.annotations.{Beta, Experimental}
import rx.exceptions.OnErrorNotImplementedException
import rx.functions.FuncN
import rx.lang.scala.observables.{AsyncOnSubscribe, ConnectableObservable, ErrorDelayingObservable, SyncOnSubscribe}

import scala.concurrent.duration
import java.util

import collection.JavaConversions._
import scala.collection.generic.CanBuildFrom
import scala.annotation.unchecked.uncheckedVariance
import scala.collection.{Iterable, Traversable, immutable}
Expand Down Expand Up @@ -4858,7 +4855,6 @@ trait Observable[+T]
*/
object Observable {
import scala.collection.JavaConverters._
import scala.collection.immutable.Range
import scala.concurrent.duration.Duration
import scala.concurrent.{Future, ExecutionContext}
import scala.util.{Success, Failure}
Expand Down
1 change: 0 additions & 1 deletion src/main/scala/rx/lang/scala/Subject.scala
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,6 @@
*/
package rx.lang.scala

import rx.annotations.Experimental
import rx.lang.scala.subjects.SerializedSubject

/**
Expand Down
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
package rx.lang.scala.observables

import rx.annotations.Experimental
import rx.lang.scala.{Notification, Observable, Subscriber}
import rx.lang.scala.{Notification, Observable}

/**
* $experimental A utility class to create [[Observable]]s that start acting when subscribed to and responds
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -334,7 +334,6 @@ class BlockingObservable[+T] private[scala] (val o: Observable[T])
// "implementation restriction: nested class is not allowed in value class.
// This restriction is planned to be removed in subsequent releases."
private[observables] class WithFilter[+T] (p: T => Boolean, asJava: rx.observables.BlockingObservable[_ <: T]) {
import rx.lang.scala.ImplicitFunctionConversions._

// there's no map and flatMap here, they're only available on Observable

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@
package rx.lang.scala.observables

import rx.annotations.Beta
import rx.lang.scala.{Observable, Subscription, Subscriber}
import rx.lang.scala.{Observable, Subscription}
import rx.lang.scala.JavaConversions._

/**
Expand Down
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
package rx.lang.scala.observables

import rx.annotations.Experimental
import rx.lang.scala.{Notification, Observable, Subscriber}
import rx.lang.scala.Notification

/**
* $experimental A utility class to create [[Observable]]s that start acting when subscribed to and responds
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -21,7 +21,7 @@ import scala.concurrent.duration.Duration
import rx.{Subscriber => JSubscriber, Observer => JObserver, Subscription => JSubscription}
import rx.annotations.Experimental
import rx.observers.{TestSubscriber => JTestSubscriber}
import rx.lang.scala.{Observable, Observer, Subscriber}
import rx.lang.scala.{Observer, Subscriber}

/**
* A [[TestSubscriber]] is a variety of [[Subscriber]] that you can use for unit testing, to perform
Expand Down
1 change: 0 additions & 1 deletion src/test/scala/rx/lang/scala/ConstructorTest.scala
Original file line number Diff line number Diff line change
Expand Up @@ -14,7 +14,6 @@
* limitations under the License.
*/
package rx.lang.scala
import scala.language.postfixOps
import org.junit.Assert._
import org.junit.Test
import org.scalatest.junit.JUnitSuite
Expand Down
6 changes: 1 addition & 5 deletions src/test/scala/rx/lang/scala/NotificationTests.scala
Original file line number Diff line number Diff line change
Expand Up @@ -16,13 +16,9 @@
package rx.lang.scala


import org.junit.{Assert, Test}
import org.junit.Test
import org.junit.Assert._
import org.scalatest.junit.JUnitSuite
import scala.concurrent.duration._
import scala.language.postfixOps
import org.mockito.Mockito._
import org.mockito.Matchers._
import rx.lang.scala.Notification.{OnCompleted, OnError, OnNext}


Expand Down
4 changes: 0 additions & 4 deletions src/test/scala/rx/lang/scala/ObservableTest.scala
Original file line number Diff line number Diff line change
Expand Up @@ -24,11 +24,7 @@ import org.junit.Assert._
import org.junit.{ Ignore, Test }
import org.scalatest.junit.JUnitSuite
import scala.concurrent.duration._
import scala.language.postfixOps
import rx.lang.scala.schedulers.TestScheduler
import rx.lang.scala.subjects.BehaviorSubject
import org.mockito.Mockito._
import org.mockito.Matchers._

class ObservableTests extends JUnitSuite {

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,7 @@ import org.scalatest.junit.JUnitSuite
import rx.lang.scala.observers.TestSubscriber

import scala.concurrent.Future
import scala.util.{Failure, Success, Try}
import scala.util.{Failure, Success}

class ScalaTypesConversionsTests extends JUnitSuite {

Expand Down
1 change: 0 additions & 1 deletion src/test/scala/rx/lang/scala/SubjectTests.scala
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,6 @@
*/
package rx.lang.scala

import scala.language.postfixOps

import org.junit.Assert.{assertEquals, assertFalse, assertTrue}
import org.junit.{Assert, Test}
Expand Down
8 changes: 1 addition & 7 deletions src/test/scala/rx/lang/scala/SubscriptionTests.scala
Original file line number Diff line number Diff line change
Expand Up @@ -16,14 +16,8 @@
package rx.lang.scala


import org.junit.{Assert, Test}
import org.junit.Assert
import org.junit.Test
import org.scalatest.junit.JUnitSuite
import scala.concurrent.duration._
import scala.language.postfixOps
import org.mockito.Mockito._
import org.mockito.Matchers._
import org.junit.Assert.assertEquals
import org.junit.Assert.assertTrue
import org.junit.Assert.assertFalse
import rx.lang.scala.subscriptions.{SerialSubscription, MultipleAssignmentSubscription, CompositeSubscription}
Expand Down

0 comments on commit 1ab7f78

Please sign in to comment.