FilesExpand file tree

 master

/

Main.scala

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

47 lines (34 loc) · 1.63 KB

 master

/

Main.scala

Copy path

Top

File metadata and controls

• Code
• Blame

47 lines (34 loc) · 1.63 KB

Raw

Copy raw file

Download raw file

Open symbols panel

Edit and raw actions

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

39

40

import coursera.adventure.unsafe.Adventure

import coursera.rx._

import coursera.usgs.{Magnitude, Usgs}

import rx.lang.scala.{Scheduler, Observable}

import rx.lang.scala.subjects._

import scala.language.postfixOps

import scala.concurrent.duration._

object Main {

def main(args: Array[String]): Unit = {

// coursera.rx.HelloObservables.ticks()

// Quizzes.quizI()

// Nested.flattenNestedStreams()

// Nested.concatenateNestedStreams()

// EarthQuakes.quakes().subscribe(println(_))

// EarthQuakes.major().subscribe(println(_))

// EarthQuakes.ofMagnitude(Magnitude.Minor).subscribe(println(_))

// EarthQuakes.withCountryMerged().subscribe(println(_), e => println(e.getMessage), () => println(">>>>>>"))

// EarthQuakes.withCountryConcatenated().subscribe(println(_), e => println(e.getMessage), () => println(">>>>>>"))

// EarthQuakes.groupedByCountry().subscribe(println(_), e => println(e.getMessage), () => println(">>>>>>"))

// Subscriptions.FishingI()

// Subscriptions.FishingII()

// Subscriptions.Composite()

// Subscriptions.Multi()

// Creation.from(Range(1,10).inclusive).subscribe(println(_))

// Creation.startWith(Observable(4,5,6), 0, 1, 2, 3).subscribe(println(_))

// Creation.filter(Observable(Range(1,10).inclusive), (x: Int) => x%2 == 0).subscribe(println(_))

// Creation.map(Observable(Range(1,10).inclusive), (x: Int) => x*2).subscribe(println(_))

// coursera.rx.Subjects.PublishSubjectIsAChannel()

// Subjects.ReplaySubjectIsAChannel()

// Subjects.AsyncSubjectIsAFuture()

// Subjects.BehaviorSubjectIsACache()

// Blocking.dontDoThisAtHomeKids()

}

}