Skip to content

Instantly share code, notes, and snippets.

View nitayneeman's full-sized avatar

Nitay Neeman nitayneeman

View GitHub Profile
Rx.Observable
.range(1, 25)
.last((value) => value % 3 === 0)
.subscribe(
(value) => console.log(`Emitted value: ${value}`),
(error) => console.error(error),
() => console.log('Completed')
);
Rx.Observable
.fromEvent(document, 'mousemove')
.throttleTime(250)
.take(7)
.subscribe(
(value) => console.log(`Emitted value: ${value}`),
(error) => console.error(error),
() => console.log('Completed')
);
const stopButton = document.querySelector('#stop-button');
let isDone = false;
Rx.Observable
.fromEvent(stopButton, 'click')
.first()
.subscribe(
() => isDone = true,
(error) => console.error(error),
const stopButton = document.querySelector('#stop-button');
const stop$ = Rx.Observable
.fromEvent(stopButton, 'click')
.first();
stop$
.subscribe(
() => {},
(error) => console.error(error),
const stopButton = document.querySelector('#stop-button');
const intervalSubscription = Rx.Observable
.interval(1000)
.subscribe(
(value) => console.log(`Emitted value: ${value}`),
(error) => console.error(error),
() => console.log('Interval completed')
);
@NgModule({
imports: [
BrowserModule,
FormsModule,
HttpModule,
InMemoryWebApiModule.forRoot(InMemoryDataService),
AppRoutingModule
],
declarations: [
AppComponent,
const routes: Routes = [
{ path: 'dashboard', component: DashboardComponent }
];
@NgModule({
imports: [
RouterModule.forChild(routes)
],
exports: [
RouterModule
@NgModule({
imports: [
DashboardRoutingModule
],
declarations: [
DashboardComponent
],
exports: [
DashboardComponent
]
imports: [
BrowserModule,
FormsModule,
HttpModule,
InMemoryWebApiModule.forRoot(InMemoryDataService),
AppRoutingModule,
DashboardModule
]
const routes: Routes = [
{ path: 'detail/:id', component: HeroDetailComponent }
];
@NgModule({
imports: [
RouterModule.forChild(routes)
],
exports: [
RouterModule