private void syncData() {PutDataMapRequest dataMap = PutDataMapRequest.create("/count");dataMap.getDataMap().putInt(COUNT_KEY, count++);PutDataRequest request = dataMap.asPutDataRequest();PendingResult<DataApi.DataItemResult> pendingResult = Wearable.DataApi.putDataItem(mGoogleApiClient, request);
}

@Override
public void onDataChanged(DataEventBuffer dataEvents) {for (DataEvent event : dataEvents) {if (event.getType() == DataEvent.TYPE_DELETED) {Log.d(TAG, "DataItem deleted: " + event.getDataItem().getUri());} else if (event.getType() == DataEvent.TYPE_CHANGED) {Log.d(TAG, "DataItem changed: " + event.getDataItem().getUri());}}
}

private void transferAsset{Bitmap bitmap = BitmapFactory.decodeResource(getResources(), R.drawable.image);Asset asset = createAssetFromBitmap(bitmap);PutDataRequest request = PutDataRequest.create("/image");request.putAsset("profileImage", asset);Wearable.DataApi.putDataItem(mGoogleApiClient, request);
}

private void transferAsset{Bitmap bitmap = BitmapFactory.decodeResource(getResources(), R.drawable.image);Asset asset = createAssetFromBitmap(bitmap);PutDataMapRequest dataMap = PutDataMapRequest.create("/image");dataMap.getDataMap().putAsset("profileImage", asset)PutDataRequest request = dataMap.asPutDataRequest();PendingResult<DataApi.DataItemResult> pendingResult = Wearable.DataApi.putDataItem(mGoogleApiClient, request);
}

@Override
public void onDataChanged(DataEventBuffer dataEvents) {for (DataEvent event : dataEvents) {if (event.getType() == DataEvent.TYPE_CHANGED &&event.getDataItem().getUri().getPath().equals("/image")) {DataMapItem dataMapItem = DataMapItem.fromDataItem(event.getDataItem());Asset profileAsset = dataMapItem.getDataMap().getAsset("profileImage");Bitmap bitmap = loadBitmapFromAsset(profileAsset);// Do something with the bitmap
    }}
}public Bitmap loadBitmapFromAsset(Asset asset) {if (asset == null) {throw new IllegalArgumentException("Asset must be non-null");}ConnectionResult result =mGoogleApiClient.blockingConnect(TIMEOUT_MS, TimeUnit.MILLISECONDS);if (!result.isSuccess()) {return null;}// convert asset into a file descriptor and block until it's readyInputStream assetInputStream = Wearable.DataApi.getFdForAsset(mGoogleApiClient, asset).await().getInputStream();mGoogleApiClient.disconnect();if (assetInputStream == null) {Log.w(TAG, "Requested an unknown Asset.");return null;}// decode the stream into a bitmapreturn BitmapFactory.decodeStream(assetInputStream);
}

Node node; // the connected device to send the message to
GoogleApiClient mGoogleApiClient;
public static final START_ACTIVITY_PATH = "/start/MainActivity";
...SendMessageResult result = Wearable.MessageApi.sendMessage(mGoogleApiClient, node, START_ACTIVITY_PATH, null).await();if (!result.getStatus().isSuccess()) {Log.e(TAG, "ERROR: failed to send Message: " + result.getStatus());}

private Collection<String> getNodes() {HashSet <String>results = new HashSet<String>();NodeApi.GetConnectedNodesResult nodes =Wearable.NodeApi.getConnectedNodes(mGoogleApiClient).await();for (Node node : nodes.getNodes()) {results.add(node.getId());}return results;
}

@Override
public void onMessageReceived(MessageEvent messageEvent) {if (messageEvent.getPath().equals(START_ACTIVITY_PATH)) {Intent startIntent = new Intent(this, MainActivity.class);startIntent.addFlags(Intent.FLAG_ACTIVITY_NEW_TASK);startActivity(startIntent);}
}