Location Observable Sample

GeoLocator.cs

        public IObservable<GeoLocation> CurrentLocationObservable(LocationOptions options)
        {
			IObservable<GeoLocation> observable = null;

			if (!_observables.TryGetValue(options,out observable)) 
			{

				var coordinates = new Subject<GeoLocation> ();
				var geoInstance = new GeoInstance (coordinates, options);

				observable= Observable.Create<GeoLocation> ((o) => {
					geoInstance.Start ();

					var sub = coordinates.
                            Subscribe (o.OnNext, o.OnError, o.OnCompleted);


					var cd = new CompositeDisposable (sub,
						                    Disposable.Create (geoInstance.Stop),
						                    Disposable.Create (() => this.Log ().Information ("Disposed")));
					return cd;
				}).Replay(1).RefCount ();

				_observables [options] = observable;
			}

			return observable;
        }